'use strict'; const common = require('../common'); const assert = require('assert'); const initHooks = require('./init-hooks'); const { checkInvocations } = require('./hook-checks'); const dgram = require('dgram'); const hooks = initHooks(); hooks.enable(); let send; const sock = dgram .createSocket('udp4') .on('listening', common.mustCall(onlistening)) .bind(); function onlistening() { sock.send( new Buffer(2), 0, 2, sock.address().port, undefined, common.mustCall(onsent)); // init not called synchronously because dns lookup alwasy wraps // callback in a next tick even if no lookup is needed // TODO (trevnorris) submit patch to fix creation of tick objects and instead // create the send wrap synchronously. assert.strictEqual( hooks.activitiesOfTypes('UDPSENDWRAP').length, 0, 'no udpsendwrap after sock connected and sock.send called'); } function onsent() { const as = hooks.activitiesOfTypes('UDPSENDWRAP'); send = as[0]; assert.strictEqual(as.length, 1, 'one UDPSENDWRAP created synchronously when message sent'); assert.strictEqual(send.type, 'UDPSENDWRAP', 'send wrap'); assert.strictEqual(typeof send.uid, 'number', 'uid is a number'); assert.strictEqual(typeof send.triggerId, 'number', 'triggerId is a number'); checkInvocations(send, { init: 1, before: 1 }, 'when message sent'); sock.close(common.mustCall(onsockClosed)); } function onsockClosed() { checkInvocations(send, { init: 1, before: 1, after: 1 }, 'when sock closed'); } process.on('exit', onexit); function onexit() { hooks.disable(); hooks.sanityCheck('UDPSENDWRAP'); checkInvocations(send, { init: 1, before: 1, after: 1, destroy: 1 }, 'when process exits'); }