push.rocks/smartlog-receiver
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2020-06-08 08:44:06 +00:00
parent e59ca8efca
commit 82800ec56f
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ts/sl.classes.smartlogreceiver.ts
View File

@ -3,7 +3,7 @@ import * as plugins from './sl.receiver.plugins';
import { import {
ILogPackage, ILogPackage,
ILogPackageAuthenticated, ILogPackageAuthenticated,
ILogDestination ILogDestination,
} from '@pushrocks/smartlog-interfaces'; } from '@pushrocks/smartlog-interfaces';
export type TValidatorFunction = (logPackage: ILogPackage) => boolean; export type TValidatorFunction = (logPackage: ILogPackage) => boolean;
@ -36,7 +36,11 @@ export class SmartlogReceiver {
const logPackage = authenticatedLogPackageArg.logPackage; const logPackage = authenticatedLogPackageArg.logPackage;
if (authString === plugins.smarthash.sha256FromStringSync(this.passphrase)) { if (authString === plugins.smarthash.sha256FromStringSync(this.passphrase)) {
// this.smartlogInstance.log('ok', 'Message accepted'); // Message authenticated lets clean up.
logPackage.correlation ? null : (logPackage.correlation = { id: '123', type: 'none' });
logPackage.correlation.id ? null : (logPackage.correlation.id = '123');
logPackage.correlation.type ? null : (logPackage.correlation.type = 'none');
this.smartlogInstance.handleLog(logPackage); this.smartlogInstance.handleLog(logPackage);
return { status: 'ok' }; return { status: 'ok' };
} else { } else {