fix(core): update

This commit is contained in:
Philipp Kunz 2019-09-18 12:26:31 +02:00
parent ec86352b58
commit e854a62eae
4 changed files with 89 additions and 21 deletions

29
.vscode/launch.json vendored Normal file
View File

@ -0,0 +1,29 @@
{
"version": "0.2.0",
"configurations": [
{
"name": "current file",
"type": "node",
"request": "launch",
"args": [
"${relativeFile}"
],
"runtimeArgs": ["-r", "@gitzone/tsrun"],
"cwd": "${workspaceRoot}",
"protocol": "inspector",
"internalConsoleOptions": "openOnSessionStart"
},
{
"name": "test.ts",
"type": "node",
"request": "launch",
"args": [
"test/test.ts"
],
"runtimeArgs": ["-r", "@gitzone/tsrun"],
"cwd": "${workspaceRoot}",
"protocol": "inspector",
"internalConsoleOptions": "openOnSessionStart"
}
]
}

View File

@ -8,11 +8,11 @@ import * as slackme from '../ts/index';
let testSlackme: slackme.Slackme; let testSlackme: slackme.Slackme;
let testSlackMessage: slackme.SlackMessage; let testSlackMessage: slackme.SlackMessage;
tap.test('should create a valid slackme instance', async () => { tap.test('should create a valid slackme instance', async (tools) => {
testSlackme = new slackme.Slackme(testQenv.getEnvVarOnDemand('SLACK_TOKEN')); testSlackme = new slackme.Slackme(testQenv.getEnvVarOnDemand('SLACK_TOKEN'));
}); });
tap.test('should send a message to Slack', async () => { tap.test('should send a message to Slack', async (tools) => {
testSlackMessage = new slackme.SlackMessage({ testSlackMessage = new slackme.SlackMessage({
author_name: 'GitLab CI', author_name: 'GitLab CI',
author_link: 'https://gitlab.com/', author_link: 'https://gitlab.com/',
@ -29,14 +29,12 @@ tap.test('should send a message to Slack', async () => {
value: 'pushrocks', value: 'pushrocks',
short: true short: true
} }
], ]
ts: new Date().getTime() / 1000
}); });
await testSlackme.sendMessage(testSlackMessage.messageOptions, 'random'); await testSlackme.sendMessage(testSlackMessage.messageOptions, 'random');
await expect(testSlackMessage.sendToRoom('random')).to.eventually.be.rejected;
}); });
tap.test('should send a message to Slack by directly calling the message', async () => { tap.test('should send a message to Slack by directly calling the message', async (tools) => {
testSlackMessage = new slackme.SlackMessage( testSlackMessage = new slackme.SlackMessage(
{ {
author_name: 'GitLab CI', author_name: 'GitLab CI',
@ -54,12 +52,30 @@ tap.test('should send a message to Slack by directly calling the message', async
value: 'pushrocks', value: 'pushrocks',
short: true short: true
} }
], ]
ts: new Date().getTime() / 1000
}, },
testSlackme testSlackme
); );
await testSlackMessage.sendToRoom('random'); await testSlackMessage.sendToRoom('random');
await tools.delayFor(5000);
await testSlackMessage.updateAndSend({
author_name: 'GitLab CI',
author_link: 'https://gitlab.com/',
pretext: '*Good News*: Build successfull!',
color: '#3cb371',
fields: [
{
title: 'Branch',
value: 'Lossless Studio',
short: true
},
{
title: 'Product ID',
value: 'pushrocks',
short: true
}
]
})
}); });
tap.start(); tap.start();

View File

@ -2,19 +2,34 @@ import * as plugins from './slack.plugins';
import { IMessageOptions } from './slack.classes.slackmessage'; import { IMessageOptions } from './slack.classes.slackmessage';
export class Slackme { export class Slackme {
private baseUrl = 'https://hooks.slack.com/services/'; private postUrl = 'https://slack.com/api/chat.postMessage';
private postRoute: string; private updateUrl = 'https://slack.com/api/chat.update';
constructor(postRouteArg: string) { private slackToken: string;
this.postRoute = postRouteArg; constructor(slackTokenArg: string) {
this.slackToken = slackTokenArg;
} }
async sendMessage(messageOptionsArg: IMessageOptions, channelArg: string = 'general') { async sendMessage(messageOptionsArg: IMessageOptions, channelArg: string = 'status', tsArg?: string) {
const response = await plugins.smartrequest.postJson(`${this.baseUrl}${this.postRoute}`, { let requestBody: any = {
requestBody: { channel: channelArg,
channel: channelArg, attachments: [messageOptionsArg]
attachments: [messageOptionsArg] }
let postUrl = this.postUrl;
if (tsArg) {
requestBody = {
...requestBody,
ts: tsArg
} }
postUrl = this.updateUrl;
}
console.log(requestBody);
const response = await plugins.smartrequest.postJson(postUrl, {
headers: {
'Authorization': `Bearer ${this.slackToken}`
},
requestBody
}); });
console.log(response.body);
return response; return response;
} }
} }

View File

@ -49,24 +49,32 @@ export interface IMessageOptions {
thumb_url?: string; thumb_url?: string;
footer?: string; footer?: string;
footer_icon?: string; footer_icon?: string;
/**
* timestamp as epoch time
*/
ts?: number; ts?: number;
} }
export class SlackMessage { export class SlackMessage {
slackmeRef: Slackme; slackmeRef: Slackme;
messageOptions: IMessageOptions; messageOptions: IMessageOptions;
channel: string;
ts: string;
constructor(messageOptionsArg: IMessageOptions, slackmeArg?: Slackme) { constructor(messageOptionsArg: IMessageOptions, slackmeArg?: Slackme) {
if (slackmeArg) { if (slackmeArg) {
this.slackmeRef = slackmeArg; this.slackmeRef = slackmeArg;
} }
this.messageOptions = messageOptionsArg; this.messageOptions = messageOptionsArg;
} }
async updateAndSend(messageOptionsArg: IMessageOptions) {
this.messageOptions = messageOptionsArg;
await this.sendToRoom(this.channel);
}
async sendToRoom(roomNameArg: string) { async sendToRoom(roomNameArg: string) {
this.channel = roomNameArg;
if (this.slackmeRef) { if (this.slackmeRef) {
await this.slackmeRef.sendMessage(this.messageOptions, roomNameArg); const response = await this.slackmeRef.sendMessage(this.messageOptions, roomNameArg, this.ts);
this.ts = response.body.message.ts;
this.channel = response.body.channel;
} else { } else {
throw new Error('you need to set a slackRef before sending the message!'); throw new Error('you need to set a slackRef before sending the message!');
} }