Saas 4802 (#388)

*Introduce agent crud

Author: oren-codefresh

lib/interface/cli/commands/agent/apply.cmd.js

@@ -0,0 +1,61 @@
+const Command = require('../../Command');
+const CFError = require('cf-errors');
+const { sdk } = require('../../../../logic');
+
+const applyRoot = require('../root/apply.cmd');
+const { ignoreHttpError } = require('../../helpers/general');
+
+const command = new Command({
+    command: 'agent [id|name]',
+    aliases: [],
+    parent: applyRoot,
+    description: 'Patch an agent',
+    webDocs: {
+        category: 'Agents',
+        title: 'Patch Agent',
+    },
+    builder: (yargs) => {
+        yargs
+            .positional('id|name', {
+                describe: 'agent id or name',
+            })
+            .option('newName', {
+                describe: 'New name',
+                alias: 'n',
+            })
+            .option('runtimes', {
+                array: true,
+                alias: 're',
+                describe: 'Agent runtimes',
+            })
+            .example(
+                'codefresh patch agent ID --name NEW_NAME',
+                'Replace agent name. Specifying agent by ID',
+            )
+            .example(
+                'codefresh patch agent NAME --re runtime1',
+                'Replace agent runtimes. Specifying agent by NAME',
+            );
+
+        return yargs;
+    },
+    handler: async (argv) => {
+        const { id, name } = argv;
+
+        const {
+            newName,
+            runtimes,
+        } = argv;
+
+        let agent = await sdk.agents.get({ agentId: id }).catch(ignoreHttpError);
+        agent = agent || await sdk.agents.getByName({ name }).catch(ignoreHttpError);
+        if (!agent) {
+            throw new CFError(`No such agent: "${name || id}"`);
+        }
+
+        await sdk.agents.replace({ agentId: agent.id }, { name: newName, runtimes });
+        console.log(`Agent: "${name || id}" patched.`);
+    },
+});
+
+module.exports = command;

lib/interface/cli/commands/agent/create.cmd.js

@@ -0,0 +1,38 @@
+const Command = require('../../Command');
+const { sdk } = require('../../../../logic');
+const createRoot = require('../root/create.cmd');
+
+
+const command = new Command({
+    command: 'agent <name>',
+    parent: createRoot,
+    description: 'Create an agent',
+    usage: 'Create an agent used to behind firewall integration.',
+    webDocs: {
+        category: 'Agents',
+        title: 'Create Agent',
+    },
+    builder: yargs => yargs
+        .positional('name', {
+            describe: 'Name of agent',
+        })
+        .option('runtimes', {
+            array: true,
+            alias: 'r',
+            describe: 'Agent runtimes',
+            default: [],
+        })
+        .example('codefresh create agent NAME', 'Create an agent')
+        .example('codefresh create agent NAME -r runtime1 -r runtime2', 'Create an agent with runtimes: [ "runtime1", "runtime2"]'),
+    handler: async (argv) => {
+        const {
+            name,
+            runtimes,
+        } = argv;
+
+        const agent = await sdk.agents.create({ name, runtimes });
+        console.log(`Agent: "${agent.name}" created with token ${agent.token}`);
+    },
+});
+
+module.exports = command;

lib/interface/cli/commands/agent/delete.cmd.js

@@ -0,0 +1,39 @@
+const Command = require('../../Command');
+const CFError = require('cf-errors');
+const { sdk } = require('../../../../logic');
+const deleteRoot = require('../root/delete.cmd');
+const { ignoreHttpError } = require('../../helpers/general');
+
+const command = new Command({
+    command: 'agent <id|name>',
+    aliases: [],
+    parent: deleteRoot,
+    description: 'Delete an agent',
+    webDocs: {
+        category: 'Agemts',
+        title: 'Delete Agent',
+    },
+    builder: (yargs) => {
+        yargs
+            .positional('id|name', {
+                describe: 'agent id or name',
+            })
+            .example('codefresh delete agent NAME', 'Delete agent by name.')
+            .example('codefresh delete agent ID', 'Delete agent by Id.');
+        return yargs;
+    },
+    handler: async (argv) => {
+        const { id, name } = argv;
+
+        let agent = await sdk.agents.get({ agentId: id }).catch(ignoreHttpError);
+        agent = agent || await sdk.agents.getByName({ name }).catch(ignoreHttpError);
+        if (!agent) {
+            throw new CFError(`No such agent: "${name || id}"`);
+        }
+
+        await sdk.agents.delete({ agentId: agent.id });
+        console.log(`Agent '${name || id}' deleted.`);
+    },
+});
+
+module.exports = command;

lib/interface/cli/commands/agent/get.cmd.js

@@ -0,0 +1,44 @@
+const Command = require('../../Command');
+const { sdk } = require('../../../../logic');
+const Agent = require('../../../../logic/entities/Agent');
+const Output = require('../../../../output/Output');
+const _ = require('lodash');
+const { ignoreHttpError } = require('../../helpers/general');
+
+const getRoot = require('../root/get.cmd');
+
+const command = new Command({
+    command: 'agents [id|name]',
+    aliases: ['agent'],
+    parent: getRoot,
+    description: 'Get a specific agent or an array of agents',
+    webDocs: {
+        category: 'Agents',
+        title: 'Get Agents',
+    },
+    builder: yargs => yargs
+        .positional('id|name', {
+            describe: 'Agent id or name to get one agent',
+        })
+        .option('name', {
+            alias: 'n',
+            describe: 'Agent name to filter by',
+        }),
+    handler: async (argv) => {
+        const { id, name } = argv; // eslint-disable-line
+
+        let agents;
+        if (id) {
+            let agent = await sdk.agents.get({ agentId: id }).catch(ignoreHttpError);
+            agent = agent || await sdk.agents.getByName({ name }).catch(ignoreHttpError);
+            agents = agent ? [agent] : [];
+        } else {
+            agents = await sdk.agents.list({
+                name,
+            });
+        }
+        Output.print(_.map(agents, Agent.fromResponse));
+    },
+});
+
+module.exports = command;

lib/logic/entities/Agent.js

@@ -0,0 +1,20 @@
+const _ = require('lodash');
+const Entity = require('./Entity');
+
+class Agent extends Entity {
+    constructor(data) {
+        super();
+        this.entityType = 'agent';
+        this.id = data.id;
+        this.name = data.name;
+        this.runtimes = data.runtimes;
+        this.defaultColumns = ['name', 'runtimes'];
+    }
+
+    static fromResponse(response) {
+        return new Agent(_.pick(response, 'id', 'name', 'runtimes'));
+    }
+}
+
+module.exports = Agent;
+