"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.deleteChannel = exports.updateChannel = exports.createChannel = exports.getChannel = exports.API_VERSION = void 0;
const apiv2_1 = require("../apiv2");
const api_1 = require("../api");
const lodash_1 = require("lodash");
const proto_1 = require("./proto");
exports.API_VERSION = "v1";
const client = new apiv2_1.Client({
    urlPrefix: api_1.eventarcOrigin,
    auth: true,
    apiVersion: exports.API_VERSION,
});
async function getChannel(name) {
    const res = await client.get(name);
    if (res.status === 404) {
        return undefined;
    }
    return res.body;
}
exports.getChannel = getChannel;
async function createChannel(channel) {
    const pathParts = channel.name.split("/");
    const res = await client.post(pathParts.slice(0, -1).join("/"), channel, {
        queryParams: { channelId: (0, lodash_1.last)(pathParts) },
    });
    return res.body;
}
exports.createChannel = createChannel;
async function updateChannel(channel) {
    const res = await client.put(channel.name, channel, {
        queryParams: {
            updateMask: (0, proto_1.fieldMasks)(channel).join(","),
        },
    });
    return res.body;
}
exports.updateChannel = updateChannel;
async function deleteChannel(name) {
    await client.delete(name);
}
exports.deleteChannel = deleteChannel;