@seneca/repl
Advanced tools
Comparing version 9.0.0 to 9.0.1
@@ -35,3 +35,2 @@ const { Duplex } = require('stream') | ||
_write(chunk, encoding, done) { | ||
// console.log('write', chunk) | ||
this.processing = true | ||
@@ -56,4 +55,2 @@ let cmd = chunk.toString() | ||
// console.log('params',params) | ||
const command = new InvokeCommand(params) | ||
@@ -63,10 +60,6 @@ | ||
(data) => { | ||
// console.log('data', data) | ||
if (200 === data.StatusCode) { | ||
let json = Buffer.from(data.Payload).toString() | ||
// console.log('json', json) | ||
const res = JSON.parse(json) | ||
// console.log('res', res) | ||
const body = JSON.parse(res.body) | ||
// console.log('body', body) | ||
@@ -109,4 +102,2 @@ let out = '' | ||
_read(size) { | ||
// console.log('read', this.processing, this.buffer) | ||
if (this.processing) { | ||
@@ -130,4 +121,2 @@ return | ||
module.exports = function makeProtocol(spec) { | ||
// console.log('MP AWS', spec) | ||
let duplex = null | ||
@@ -151,4 +140,2 @@ | ||
}) | ||
// console.log(duplex) | ||
} else { | ||
@@ -158,4 +145,3 @@ throw new Error('Unknown AWS service: ' + service) | ||
// console.log('PAWS', !!duplex) | ||
return duplex | ||
} |
@@ -268,4 +268,2 @@ #!/usr/bin/env node | ||
state.connection.sock.on('data', function (chunk) { | ||
// console.log('CHUNK', chunk.length, chunk.toString('ascii')) | ||
if (0 < chunk.length && 0 === chunk[chunk.length - 1]) { | ||
@@ -277,3 +275,2 @@ responseChunks.push(chunk.slice(0, chunk.length - 1)) | ||
spec.first = false | ||
console.log('HANDLE-DATA<' + str + '>') | ||
handleResponse(str) | ||
@@ -280,0 +277,0 @@ } else if (0 < chunk.length) { |
@@ -48,3 +48,2 @@ "use strict"; | ||
let parts = argstr.trim().split(/\s+/); | ||
// console.log('PARTS', parts) | ||
if (0 < parts.length) { | ||
@@ -62,5 +61,3 @@ if (parts[0].match(/^plugins?$/)) { | ||
if ('string' === typeof narrow) { | ||
// console.log('FP', narrow) | ||
let plugin = context.seneca.find_plugin(narrow); | ||
// console.log('FP p', plugin) | ||
return respond(null, plugin); | ||
@@ -258,3 +255,2 @@ } | ||
args = Array.isArray(args) ? args : [args]; | ||
// console.log('DA', args, context.delegate) | ||
let name = args[0]; | ||
@@ -261,0 +257,0 @@ let fromDelegateName = args[1]; |
@@ -90,3 +90,2 @@ "use strict"; | ||
let replInst = replMap[replID]; | ||
// console.log('UR', replInst) | ||
if (replInst && 'open' === replInst.status) { | ||
@@ -155,3 +154,2 @@ return reply({ | ||
replInst.output.on('data', listener); | ||
// console.log('SC write', cmd) | ||
replInst.input.write(cmd); | ||
@@ -359,3 +357,2 @@ } | ||
evaluate(cmdtext, context, filename, origRespond) { | ||
// console.log('EVAL', cmdtext) | ||
const seneca = this.seneca; | ||
@@ -384,3 +381,2 @@ const repl = this.repl; | ||
} | ||
// console.log('AAA', cmdtext) | ||
if (alias[cmdtext]) { | ||
@@ -406,3 +402,2 @@ cmdtext = alias[cmdtext]; | ||
function execute_action(cmdtext) { | ||
// console.log('EA', cmdtext) | ||
try { | ||
@@ -417,3 +412,2 @@ let msg = cmdtext; | ||
let notmsg = null == args || Array.isArray(args) || 'object' !== typeof args; | ||
// console.log('ARGS', args, notmsg) | ||
if (notmsg) { | ||
@@ -459,3 +453,2 @@ return false; | ||
function execute_script(cmdtext) { | ||
// console.log('EVAL SCRIPT', cmdtext) | ||
try { | ||
@@ -462,0 +455,0 @@ let script = node_vm_1.default.createScript(cmdtext, { |
{ | ||
"name": "@seneca/repl", | ||
"description": "Provides a client and server REPL for Seneca microservice systems.", | ||
"version": "9.0.0", | ||
"version": "9.0.1", | ||
"main": "dist/repl.js", | ||
@@ -51,3 +51,3 @@ "license": "MIT", | ||
"devDependencies": { | ||
"@aws-sdk/client-lambda": "^3.568.0", | ||
"@aws-sdk/client-lambda": "^3.569.0", | ||
"@seneca/entity-util": "^2.0.0", | ||
@@ -61,3 +61,3 @@ "@seneca/gateway-auth": "^1.0.2", | ||
"prettier": "^3.2.5", | ||
"seneca": "^3.35.3", | ||
"seneca": "^3.36.0", | ||
"seneca-doc": "^2.1.3", | ||
@@ -64,0 +64,0 @@ "seneca-entity": "^25.1.3", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
96653
1596