dns-records-list.js

/**
 * Copyright 2020 Google Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * This node provides DLP processing.  We will assume that msg.payload
 * contains the original data that may contain sensistive data.
 * 
 * The configuration for the node includes:
 *
 */
/* jshint esversion: 8 */
module.exports = function(RED) {
    "use strict";
    const NODE_TYPE = "google-cloud-dns-records-list";
    const {DNS} = require('@google-cloud/dns');

    function DnsRecordsListNode(config) {
        RED.nodes.createNode(this, config);
        const node = this;

        let dnsOptions = {
            projectId: config.projectId,
        };
        if (config.account) {
            dnsOptions.credentials = JSON.parse(RED.nodes.getCredentials(node).account);
        } else if (config.keyFilename) {
            dnsOptions.keyFilename = config.keyFilename;
        }
        const dns = new DNS(dnsOptions);
        const zone = dns.zone(config.managedZone);

        // Converts a Record from the DNS library into a
        // https://cloud.google.com/dns/docs/reference/v1/resourceRecordSets#resource.
        function fromRecord(record) {
            return {
                "kind": "dns#resourceRecordSet",
                "name": record.name,
                "type": record.type,
                "ttl": record.ttl,
                "rrdatas": record.data,
                "signatureRrdatas": record.signatureRrdatas,
            };
        }

        // Called when a message arrives at the node.
        node.on("input", async function(msg) {
            try {
                msg.response = await zone.getRecords({
                    maxResults: msg.maxResults,
                    name: msg.name,
                    pageToken: msg.pageToken,
                    type: msg.type,
                });
            } catch (exp) {
                node.error(exp);
                msg.error = exp;
                return;
            }
            const [records,] = msg.response;
            msg.payload = records.map(fromRecord);
            node.send(msg);
        });
    }

    RED.nodes.registerType(NODE_TYPE, DnsRecordsListNode);
};