| const { Readable } = require('node:stream'); | |
| const DocumentSource = require('./documentsource'); | |
| module.exports = class DocumentClientQueryReadable extends Readable { | |
| constructor (client, params) { | |
| super({ objectMode: true }); | |
| this.source = new DocumentSource(client, params); | |
| this.source.on('data', this.onData.bind(this)); | |
| this.source.on('end', this.onEnd.bind(this)); | |
| } |
| const arc = require('@architect/functions'); | |
| const { GetObjectCommand, S3Client } = require('@aws-sdk/client-s3'); | |
| const { Upload } = require('@aws-sdk/lib-storage'); | |
| const client = new S3Client({}); | |
| const CONSTANTS = require('@architect/shared/constants'); | |
| const { timer } = require('@architect/shared/utils'); | |
| const jsonlines = require('@jsonlines/core') | |
| const stream = require('stream'); | |
| /* |
| // Some user-defined parameters based on primitive types | |
| type BaseParamDefinition<N, T> = { type: N; default: T }; | |
| type BooleanParamDefinition = BaseParamDefinition<"boolean", boolean>; | |
| type StringParamDefinition = BaseParamDefinition<"string", string>; | |
| type NumberParamDefinition = BaseParamDefinition<"number",number>; | |
| // A more complex parameter type: an object, with inputs, and an array that specifies which of the inputs are required. | |
| type ObjectParamDefinition< | |
| Inputs extends ParameterSetDefinition<PrimitiveParameterDefinition>, | |
| RequiredInputs extends RequiredProperties<Inputs>, | |
| > = { |
| <html> | |
| <head> | |
| <title>Compass Test</title> | |
| <meta name="viewport" content="width=device-width, height=device-height, initial-scale=1.0, target-densityDpi=device-dpi" /> | |
| <script type="text/javascript" src="phonegap.0.9.6.1.js"></script> | |
| <script type="text/javascript"> | |
| var d = -45, | |
| e = null, | |
| w = null; | |
| function win(h) { |
| { | |
| "name": "axios-repro", | |
| "version": "1.0.0", | |
| "description": "", | |
| "main": "index.js", | |
| "scripts": { | |
| "test": "DEBUG=nock.scope* mocha test.js" | |
| }, | |
| "keywords": [], | |
| "author": "", |
| const { App } = require('@slack/bolt'); | |
| // Initializes your app with your bot token and signing secret | |
| const app = new App({ | |
| token: process.env.SLACK_BOT_TOKEN, | |
| signingSecret: process.env.SLACK_SIGNING_SECRET, | |
| socketMode: true, | |
| appToken: process.env.SLACK_APP_TOKEN | |
| }); | |
| // Listens to incoming messages that contain "hello" |
| const queue = 'MyDopeassQueue'; | |
| const dlq = `${queue}DLQ`; | |
| module.exports = function queueCustomizer (arc, cloudformation) { | |
| cloudformation.Resources[queue] = { | |
| Type: 'AWS::SQS::Queue', | |
| DependsOn: dlq, | |
| Properties: { | |
| MessageRetentionPeriod: 1209600, // max (14 days) | |
| ReceiveMessageWaitTimeSeconds: 20, // enable long polling when asking for messages |
NOTES:
p1 referred to below is simply the name given to the LXC. You can change this if you want, just remember to always refer to the same container name :PVagrantfile's only network config is:config.vm.network "public_network", :bridge => 'en0: Wi-Fi (AirPort)'
| let fs = require('fs'); | |
| const INDEX_HTML = 'public/index.html'; | |
| const INDEX_ROUTE = 'src/http/get-index/index.js'; | |
| let html = fs.readFileSync(INDEX_HTML).toString(); | |
| let route = fs.readFileSync(INDEX_ROUTE).toString(); | |
| route = route.replace(/`.*`/, '`' + html + '`'); // replace everything between two backticks with index.html. that's my sophisticated templating engine! | |
| console.log('\nOverwriting index route to return new index.html...'); | |
| fs.writeFileSync(INDEX_ROUTE, route, 'utf-8'); |
| var app = { | |
| // Application Constructor | |
| initialize: function() { | |
| document.addEventListener('deviceready', this.onDeviceReady.bind(this), false); | |
| }, | |
| // deviceready Event Handler | |
| // | |
| // Bind any cordova events here. Common events are: | |
| // 'pause', 'resume', etc. |