How to use initServer method in Playwright Internal

Best JavaScript code snippet using playwright-internal

sse-channel.test.js

Source:sse-channel.test.js Github

copy

Full Screen

...13 this.timeout(5000);14 var port = process.env.TESTING_PORT || 6775;15 var host = 'http://localhost:' + port;16 var server, channel, es, path = '/sse';17 function initServer(opts) {18 var tmp = serverInit(merge({}, { port: port, path: path }, opts || {}));19 server = tmp.server;20 channel = tmp.channel;21 return channel;22 }23 afterEach(function(done) {24 if (es) {25 es.close();26 }27 if (channel) {28 channel.close();29 }30 if (server && server.close) {31 server.close(done);32 return;33 }34 done();35 });36 it('can be constructed without options', function() {37 assert.doesNotThrow(function() {38 channel = new SseChannel();39 }, 'should not throw if constructed without options');40 });41 it('can broadcast simple message', function(done) {42 initServer();43 var text = 'First event!';44 channel.on('connect', function() {45 channel.send(text);46 });47 es = new EventSource(host + path);48 es.onmessage = function(e) {49 assert.strictEqual(e.data, text);50 done();51 };52 });53 it('represents messages without event name as "message"', function(done) {54 initServer();55 channel.on('connect', function() {56 channel.send('Moo');57 });58 es = new EventSource(host + path);59 es.onmessage = function(e) {60 assert.strictEqual(e.type, 'message');61 done();62 };63 });64 it('addClient calls the specified callback when finished serving initial data', function(done) {65 initServer({66 addClientCallback: function(err) {67 assert.ifError(err);68 done();69 }70 });71 es = new EventSource(host + path);72 });73 it('can send messages to specific clients', function(done) {74 initServer();75 var privText = 'Private', count = 0;76 channel.on('connect', function(chan, req, res) {77 // Wait for two clients to connect78 if (++count !== 2) {79 return;80 }81 chan.send({ id: 1, data: privText }, [res]);82 });83 // Should not receive the message84 es = new EventSource(host + path);85 es.onmessage = function(e) {86 if (e.data === privText) {87 throw new Error('EventSource client #1 should not receive the private message');88 }89 };90 es.onopen = function() {91 // Should receive the message92 var es2 = new EventSource(host + path);93 es2.onmessage = function(e) {94 assert.strictEqual(e.data, privText);95 es2.close();96 // Ensure the history is not populated with the "private" message97 var pubText = 'Public';98 channel.send({ id: 2, data: pubText });99 var es3 = new EventSource(host + path, { headers: { 'Last-Event-Id': '0' } });100 es3.onmessage = function(e3) {101 es3.close();102 if (e3.data === privText) {103 throw new Error('"Private" message found in history');104 }105 assert.strictEqual(e3.data, pubText);106 done();107 };108 };109 };110 });111 it('can broadcast messages with ID and type', function(done) {112 initServer();113 var data = 'Reign in Citra';114 channel.on('connect', function() {115 channel.send({ event: 'drink', data: data, id: 1337 });116 });117 es = new EventSource(host + path);118 es.addEventListener('drink', function(e) {119 assert.strictEqual(e.lastEventId, '1337');120 assert.strictEqual(e.type, 'drink');121 assert.strictEqual(e.data, data);122 done();123 }, false);124 });125 it('can tell clients how long they should wait before reconnecting', function(done) {126 initServer({ retryTimeout: 3000 });127 channel.on('connect', function() {128 var disconnected;129 // Tell clients to reconnect after approx 75 milliseconds130 var retryTime = 75;131 channel.retry(retryTime);132 // Remove the 'connect'-listener (for testing purposes, since we re-apply it below)133 channel.removeAllListeners();134 // Add a new connect listener that we can use to assert with135 channel.on('connect', function() {136 var timeUsed = Date.now() - disconnected;137 assert.ok(138 timeUsed > (retryTime * 0.25) && timeUsed < (retryTime * 1.75),139 'Client did not reconnect after ~' + retryTime + 'ms ' +140 '(reconnected after ' + timeUsed + 'ms)'141 );142 done();143 });144 // Disconnect all clients on the channel145 disconnected = Date.now();146 channel.close();147 });148 es = new EventSource(host + path);149 });150 it('can provide a history of events if client is disconnected', function(done) {151 initServer();152 var id = 1337, msgCount = 0;153 for (var i = 0; i < 6; i++) {154 channel.send({ id: ++id, data: 'Event #' + id });155 }156 es = new EventSource(host + path, { headers: { 'Last-Event-Id': '1337' } });157 es.onmessage = function(e) {158 if (++msgCount !== 6) {159 return;160 }161 // Data should correspond to the last message we sent162 assert.strictEqual(e.data, 'Event #' + id);163 done();164 };165 });166 it('can provide a history of events through "evs_last_event_id"-query param', function(done) {167 initServer();168 var id = 1337, msgCount = 0;169 for (var i = 0; i < 6; i++) {170 channel.send({ id: ++id, data: 'Event #' + id });171 }172 es = new EventSource(host + path + '?evs_last_event_id=1337');173 es.onmessage = function(e) {174 if (++msgCount !== 6) {175 return;176 }177 assert.strictEqual(e.data, 'Event #' + id);178 done();179 };180 });181 it('can provide a history of events through "lastEventId"-query param', function(done) {182 initServer();183 var id = 1337, msgCount = 0;184 for (var i = 0; i < 6; i++) {185 channel.send({ id: ++id, data: 'Event #' + id });186 }187 es = new EventSource(host + path + '?lastEventId=1337');188 es.onmessage = function(e) {189 if (++msgCount !== 6) {190 return;191 }192 assert.strictEqual(e.data, 'Event #' + id);193 done();194 };195 });196 it('does not send history by default', function(done) {197 initServer();198 var id = 1337, msgCount = 0;199 for (var i = 0; i < 6; i++) {200 channel.send({ id: ++id, data: 'Event #' + id });201 }202 es = new EventSource(host + path);203 es.onopen = function() {204 channel.send('Boom');205 };206 es.onmessage = function(e) {207 if (++msgCount === 1) {208 assert.strictEqual(e.data, 'Boom');209 done();210 }211 };212 });213 it('sends the right slice of the history', function(done) {214 initServer();215 var id = 1337, msgCount = 0, lastMsg;216 for (var i = 0; i < 6; i++) {217 channel.send({ id: ++id, data: 'Event #' + id });218 }219 var assertMsgCount = debounce(function() {220 assert.strictEqual(msgCount, 4);221 assert.strictEqual(lastMsg.data, 'Event #' + id);222 done();223 }, 25);224 es = new EventSource(host + path + '?lastEventId=1339');225 es.onmessage = function(e) {226 msgCount++;227 lastMsg = e;228 assertMsgCount();229 };230 });231 it('only includes the latest event with the same ID', function(done) {232 initServer();233 var id = 1337, msgCount = 0, lastMsg;234 for (var i = 0; i < 6; i++) {235 channel.send({ id: 1337, data: 'Event #' + id });236 }237 var assertMsgCount = debounce(function() {238 assert.strictEqual(msgCount, 1);239 assert.strictEqual(lastMsg.data, 'Event #' + id);240 done();241 }, 25);242 es = new EventSource(host + path + '?lastEventId=1330');243 es.onmessage = function(e) {244 msgCount++;245 lastMsg = e;246 assertMsgCount();247 };248 });249 it('can be configured to a specific max history size', function(done) {250 initServer({ historySize: 5 });251 var id = 100, msgCount = 0, lastMsg;252 for (var i = 0; i < 100; i++) {253 channel.send({ id: ++id, data: 'Event #' + id });254 }255 var assertMsgCount = debounce(function() {256 assert.strictEqual(msgCount, 5);257 assert.strictEqual(lastMsg.data, 'Event #' + id);258 done();259 }, 25);260 es = new EventSource(host + path + '?lastEventId=110');261 es.onmessage = function(e) {262 msgCount++;263 lastMsg = e;264 assertMsgCount();265 };266 });267 it('can be given an array of events to pre-populate with', function(done) {268 var msgs = [], id = 1337;269 for (var i = 0; i < 10; i++) {270 msgs.push({ id: ++id, data: 'Event #' + id });271 }272 initServer({ historySize: 5, history: msgs });273 var msgCount = 0, lastMsg;274 var assertMsgCount = debounce(function() {275 assert.strictEqual(msgCount, 5);276 assert.strictEqual(lastMsg.data, 'Event #' + id);277 done();278 }, 25);279 es = new EventSource(host + path + '?lastEventId=1');280 es.onmessage = function(e) {281 msgCount++;282 lastMsg = e;283 assertMsgCount();284 };285 });286 it('provides a correct number of connections on channel', function(done) {287 initServer();288 var connections = channel.getConnectionCount();289 assert.strictEqual(connections, 0, 'Initial connection count should be 0, got ' + connections);290 es = new EventSource(host + path);291 es.onopen = function() {292 connections = channel.getConnectionCount();293 assert.strictEqual(294 connections,295 1,296 'Connection count after opening first connection should be 1, got ' + connections297 );298 process.nextTick(function() {299 var es2 = new EventSource(host + path);300 es2.onopen = function() {301 connections = channel.getConnectionCount();302 assert.strictEqual(303 connections,304 2,305 'Connection count after opening second connection should be 2, got ' + connections306 );307 es2.close();308 setTimeout(function() {309 connections = channel.getConnectionCount();310 assert.strictEqual(311 connections,312 1,313 'Connection count after disconnecting one session should be 1, got ' + connections314 );315 done();316 }, 25);317 };318 });319 };320 });321 it('sends automatic pings', function(done) {322 // We'll want to use some custom logic for the channel here323 var interval = 25;324 initServer({ pingInterval: interval });325 var opts = url.parse(host + path);326 opts.headers = { Accept: 'text/event-stream' };327 var req = http.request(opts, function(res) {328 var buf = '';329 res.on('data', function(chunk) {330 buf += chunk.toString();331 });332 setTimeout(function() {333 req.abort();334 assert.ok(335 buf.match(/\:\n/g).length >= 5,336 'Expected at least 5 pings within ' + (interval * 7) + 'ms'337 );338 done();339 }, interval * 7);340 });341 req.setNoDelay(true);342 req.end();343 });344 it('sends "preamble" if client requests it', function(done) {345 initServer();346 var opts = url.parse(host + path + '?evs_preamble=1');347 opts.headers = { Accept: 'text/event-stream' };348 var req = http.request(opts, function(res) {349 var buf = '';350 res.on('data', function(chunk) {351 buf += chunk.toString();352 if (buf.match(/\-{3}\n/)) {353 assert.ok(354 buf.match(/\:\-{2056,}/),355 'Preamble of 2kb not present in response'356 );357 req.abort();358 done();359 }360 });361 });362 req.setNoDelay(true);363 req.end();364 });365 it('can auto-encode data as JSON', function(done) {366 initServer({ jsonEncode: true });367 channel.on('connect', function() {368 channel.send({ data: ['foo', 'bar'] });369 channel.send({ data: { foo: 'bar' } });370 channel.send({ data: 'Foobar' });371 });372 es = new EventSource(host + path);373 es.onmessage = function(e) {374 var data = JSON.parse(e.data);375 if (Array.isArray(data)) {376 // Assume first message377 assert.strictEqual(data[0], 'foo');378 assert.strictEqual(data[1], 'bar');379 } else if (typeof data === 'string') {380 // Assume second message381 assert.strictEqual(data, 'Foobar');382 } else if (typeof data === 'object' && !data.type) {383 // Assume object, third message384 assert.strictEqual(data.foo, 'bar');385 done();386 }387 };388 });389 it('does not JSON-encode data by default', function(done) {390 initServer();391 channel.on('connect', function() {392 channel.send({ data: { foo: 'bar' } });393 });394 es = new EventSource(host + path);395 es.onmessage = function(e) {396 assert.strictEqual(e.data, '[object Object]');397 done();398 };399 });400 it('send string messages as JSON if jsonEncode is enabled', function(done) {401 initServer({ jsonEncode: true });402 channel.on('connect', function() {403 channel.send('foobar');404 });405 es = new EventSource(host + path);406 es.onmessage = function(e) {407 assert.strictEqual(e.data, '"foobar"');408 done();409 };410 });411 it('send string messages as plain string if jsonEncode is disabled', function(done) {412 initServer();413 channel.on('connect', function() {414 channel.send('foobar');415 });416 es = new EventSource(host + path);417 es.onmessage = function(e) {418 assert.strictEqual(e.data, 'foobar');419 done();420 };421 });422 it('treats missing data property as empty string', function(done) {423 initServer();424 channel.on('connect', function() {425 channel.send({ id: 1337 });426 });427 es = new EventSource(host + path);428 es.onmessage = function(e) {429 assert.strictEqual(e.data, '');430 done();431 };432 });433 it('handles multi-line strings properly', function(done) {434 initServer();435 var text = [436 'Line 1',437 'Line 2',438 '',439 'Line 4',440 'Line 5\n\n\n',441 'Line ..9?'442 ].join('\n');443 channel.on('connect', function() {444 channel.send(text);445 });446 es = new EventSource(host + path);447 es.onmessage = function(e) {448 assert.strictEqual(e.data, text);449 done();450 };451 });452 it('sends initial retry-timeout if specified in channel config', function(done) {453 initServer({ retryTimeout: 3000 });454 var opts = url.parse(host + path);455 opts.headers = { Accept: 'text/event-stream' };456 var req = http.request(opts, function(res) {457 var buf = '';458 res.on('data', function(chunk) {459 buf += chunk.toString();460 if (buf.length >= 17) {461 assert.ok(buf.indexOf('retry: 3000\n') > -1);462 req.abort();463 done();464 }465 });466 });467 req.setNoDelay(true);468 req.end();469 });470 it('single event can contain event name, retry time, id and data', function(done) {471 initServer();472 var opts = url.parse(host + path);473 opts.headers = { Accept: 'text/event-stream' };474 var req = http.request(opts, function(res) {475 var buf = '';476 res.on('data', function(chunk) {477 buf += chunk.toString();478 if (buf.indexOf('Citra') > -1) {479 assert.ok(buf.indexOf('\nevent: drink\n') > -1);480 assert.ok(buf.indexOf('\nretry: 1800\n') > -1);481 assert.ok(buf.indexOf('\nid: 1337\n') > -1);482 assert.ok(buf.indexOf('\ndata: Reign in Citra\n') > -1);483 req.abort();484 done();485 }486 });487 channel.send({ retry: 1800, id: 1337, event: 'drink', data: 'Reign in Citra' });488 });489 req.setNoDelay(true);490 req.end();491 });492 it('calls flush() after writes if the method exists on response', function(done) {493 // Initialize a server with a custom `flush()` method added on each incoming request,494 // mimicking the `compression` middleware. Check that we call `flush()`:495 // - On connect, after the initial headers, retry, and preamble has been written496 // - After "missed events" have been sent (once)497 // - After each broadcast498 var flushes = 0;499 initServer({500 flush: function() {501 flushes++;502 },503 history: [504 { id: 1338, data: 'Event #1338' },505 { id: 1339, data: 'Event #1339' }506 ]507 });508 es = new EventSource(host + path + '?lastEventId=1337&evs_preamble=1');509 es.onopen = function() {510 channel.send('We set sail from the sweet cove of Cork');511 channel.send('With seven million barrels of porter');512 };513 es.onmessage = runAfter(4, function() {514 assert.strictEqual(flushes, 4);515 done();516 });517 });518 it('emits connect/disconnect/message events', function(done) {519 channel = initServer();520 var connections = [];521 var status = {522 connect: 0,523 disconnect: 0,524 message: 0525 };526 channel.on('connect', function(chan, req, res) {527 assert.strictEqual(channel, chan);528 assert.ok(req instanceof http.IncomingMessage);529 assert.ok(res instanceof http.ServerResponse);530 if (++status.connect === 2) {531 channel.send('foobar');532 channel.send({ data: 'barfoo' }, [res]);533 }...

Full Screen

Full Screen

pergunta.test.js

Source:pergunta.test.js Github

copy

Full Screen

...11 });12 return headers['set-cookie'];13};14test('api.perguntas.create', async t => {15 const fastify = await initServer(t);16 const { _id: usuarioId } = await seed.entidades.usuario();17 const perguntaData = seed.fixtures.pergunta({ usuarioId: usuarioId.toString() });18 const { statusCode } = await fastify.inject({19 url: '/api/perguntas',20 method: 'POST',21 payload: perguntaData,22 });23 t.same(statusCode, 200);24 t.end();25});26test('api.perguntas.create', async t => {27 const fastify = await initServer(t);28 const { _id: usuarioId } = await seed.entidades.usuario();29 const perguntaData = seed.fixtures.pergunta({ usuarioId: usuarioId.toString() });30 const { statusCode } = await fastify.inject({31 url: '/api/perguntas',32 method: 'POST',33 payload: perguntaData,34 });35 t.same(statusCode, 200);36 t.end();37});38test('api.perguntas.create: cadastra com referência para usuário inválida', async t => {39 const fastify = await initServer(t);40 const usuarioId = randomObjectId();41 const perguntaData = seed.fixtures.pergunta({ usuarioId: usuarioId.toString() });42 const { statusCode, payload } = await fastify.inject({43 url: '/api/perguntas',44 method: 'POST',45 payload: perguntaData,46 });47 const { message } = JSON.parse(payload);48 t.same(message, 'Referência para usuário inválida');49 t.same(statusCode, 400);50 t.end();51});52test('api.perguntas.delete', async t => {53 const fastify = await initServer(t);54 const usuario = seed.fixtures.usuario();55 const { _id: usuarioId } = await seed.entidades.usuario(usuario);56 const pergunta = await seed.entidades.pergunta({ usuarioId });57 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });58 const { statusCode } = await fastify.inject({59 url: `/api/perguntas/${pergunta._id}`,60 method: 'DELETE',61 headers: { cookie },62 });63 t.same(statusCode, 200);64 t.end();65});66test('api.perguntas.delete: passa id inválido', async t => {67 const fastify = await initServer(t);68 const { statusCode, payload } = await fastify.inject({69 url: `/api/perguntas/${randomObjectId()}`,70 method: 'DELETE',71 });72 const { message } = JSON.parse(payload);73 t.same(message, 'Not Found');74 t.same(statusCode, 404);75 t.end();76});77test('api.perguntas.update: somente usuario que postou a pergunta pode deletá-la', async t => {78 const fastify = await initServer(t);79 const usuario1 = await seed.entidades.usuario();80 const usuario2 = seed.fixtures.usuario();81 await seed.entidades.usuario(usuario2);82 const pergunta = await seed.entidades.pergunta({ usuarioId: usuario1._id });83 const cookie = await getCookie({ fastify, payload: { username: usuario2.username, password: usuario2.password } });84 const { statusCode, payload } = await fastify.inject({85 url: `/api/perguntas/${pergunta._id}`,86 method: 'DELETE',87 headers: { cookie },88 });89 const { message } = JSON.parse(payload);90 t.same(message, 'Somente o usuário que postou a pergunta pode deletá-la');91 t.same(statusCode, 401);92 t.end();93});94test('api.perguntas.find', async t => {95 const fastify = await initServer(t);96 const pergunta = await seed.entidades.pergunta();97 const { statusCode } = await fastify.inject({98 url: `/api/perguntas/${pergunta._id}`,99 method: 'GET',100 });101 t.same(statusCode, 200);102 t.end();103});104test('api.perguntas.find: passa id inválido', async t => {105 const fastify = await initServer(t);106 const { statusCode, payload } = await fastify.inject({107 url: `/api/perguntas/${randomObjectId()}`,108 method: 'GET',109 });110 const { message } = JSON.parse(payload);111 t.same(message, 'Not Found');112 t.same(statusCode, 404);113 t.end();114});115test('api.perguntas.update', async t => {116 const fastify = await initServer(t);117 const usuario = seed.fixtures.usuario();118 const { _id: usuarioId } = await seed.entidades.usuario(usuario);119 const pergunta = await seed.entidades.pergunta({ usuarioId });120 const alteracoes = { descricao: 'pergunta atualizado' };121 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });122 const { statusCode } = await fastify.inject({123 url: `/api/perguntas/${pergunta._id}`,124 method: 'POST',125 payload: alteracoes,126 headers: { cookie },127 });128 t.same(statusCode, 200);129 t.end();130});131test('api.perguntas.update: passa id inválido', async t => {132 const fastify = await initServer(t);133 const { statusCode, payload } = await fastify.inject({134 url: `/api/perguntas/${randomObjectId()}`,135 method: 'POST',136 payload: {},137 });138 const { message } = JSON.parse(payload);139 t.same(message, 'Not Found');140 t.same(statusCode, 404);141 t.end();142});143test('api.perguntas.update: tenta atualizar usuarioId', async t => {144 const fastify = await initServer(t);145 const usuario = seed.fixtures.usuario();146 const { _id: usuarioId } = await seed.entidades.usuario(usuario);147 const pergunta = await seed.entidades.pergunta({ usuarioId });148 const alteracoes = { usuarioId: 'nao pode migao' };149 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });150 const { statusCode, payload } = await fastify.inject({151 url: `/api/perguntas/${pergunta._id}`,152 method: 'POST',153 payload: alteracoes,154 headers: { cookie },155 });156 const { message } = JSON.parse(payload);157 t.same(message, 'Referência de usuário da pergunta não deve ser alterada');158 t.same(statusCode, 400);159 t.end();160});161test('api.perguntas.update: somente usuario que postou a pergunta pode editá-la', async t => {162 const fastify = await initServer(t);163 const usuario1 = await seed.entidades.usuario();164 const usuario2 = seed.fixtures.usuario();165 await seed.entidades.usuario(usuario2);166 const pergunta = await seed.entidades.pergunta({ usuarioId: usuario1._id });167 const alteracoes = { descricao: 'pergunta atualizado' };168 const cookie = await getCookie({ fastify, payload: { username: usuario2.username, password: usuario2.password } });169 const { statusCode, payload } = await fastify.inject({170 url: `/api/perguntas/${pergunta._id}`,171 method: 'POST',172 payload: alteracoes,173 headers: { cookie },174 });175 const { message } = JSON.parse(payload);176 t.same(message, 'Somente o usuário que postou a pergunta pode editá-la');177 t.same(statusCode, 401);178 t.end();179});180test('api.perguntas.usuarios', async t => {181 const fastify = await initServer(t);182 const usuario = await seed.entidades.usuario();183 await seed.entidades.pergunta({ usuarioId: usuario._id });184 const { statusCode } = await fastify.inject({185 url: `/api/perguntas/usuarios/${usuario._id}`,186 method: 'GET',187 });188 t.same(statusCode, 200);189 t.end();190});191test('api.perguntas.search: pesquisa por tags', async t => {192 const fastify = await initServer(t);193 const { _id: usuarioId } = await seed.entidades.usuario();194 const perguntaData = seed.fixtures.pergunta({ usuarioId, tags: ['teste1', 'teste2'] });195 await fastify.core.models.pergunta.create(perguntaData);196 const filter = utils.serialize({ tags: ['teste1', 'teste2'] });197 const { statusCode, payload } = await fastify.inject({198 url: '/api/perguntas/search?' + filter,199 method: 'GET',200 });201 const { total } = JSON.parse(payload);202 t.same(statusCode, 200);203 t.same(total, 1);204 t.end();205});206test('api.perguntas.search: pesquisa por uma única tag', async t => {207 const fastify = await initServer(t);208 const { _id: usuarioId } = await seed.entidades.usuario();209 const perguntaData = seed.fixtures.pergunta({ usuarioId, tags: ['teste1', 'teste2'] });210 await fastify.core.models.pergunta.create(perguntaData);211 const filter = utils.serialize({ tags: 'teste1' });212 const { statusCode, payload } = await fastify.inject({213 url: '/api/perguntas/search?' + filter,214 method: 'GET',215 });216 const { total } = JSON.parse(payload);217 t.same(statusCode, 200);218 t.same(total, 1);219 t.end();220});221test('api.perguntas.search: pesquisa por keyword', async t => {222 const fastify = await initServer(t);223 const keyword = 'titulo esotérico';224 await seed.entidades.pergunta({ titulo: 'um titulo esotérico aí' });225 const filter = utils.serialize({ keyword });226 const { statusCode, payload } = await fastify.inject({227 url: '/api/perguntas/search?' + filter,228 method: 'GET',229 });230 const { total } = JSON.parse(payload);231 t.same(statusCode, 200);232 t.same(total, 1);233 t.end();234});235test('api.perguntas.search: pesquisa sem filtro', async t => {236 const fastify = await initServer(t);237 await seed.entidades.pergunta();238 const { statusCode, payload } = await fastify.inject({239 url: '/api/perguntas/search?',240 method: 'GET',241 });242 const { total } = JSON.parse(payload);243 t.same(statusCode, 200);244 t.same(total, 0);245 t.end();246});247test('api.perguntas.trending', async t => {248 const fastify = await initServer(t);249 const titulos = ['titulo 2', 'titulo 3', 'titulo 1'];250 await seed.entidades.pergunta({ titulo: titulos[1], upvotes: 2, downvotes: 3 });251 await seed.entidades.pergunta({ titulo: titulos[0], upvotes: 3, downvotes: 3 });252 await seed.entidades.pergunta({ titulo: titulos[2], upvotes: 4, downvotes: 1 });253 const { statusCode, payload } = await fastify.inject({254 url: '/api/perguntas/trending',255 method: 'GET',256 });257 const { elements, total } = JSON.parse(payload);258 t.same(statusCode, 200);259 t.same(total, 3);260 elements.forEach(({ titulo }, index) => {261 t.same(titulo, titulos[index]);262 });263 t.end();264});265test('api.perguntas.trending: skip & limit', async t => {266 const fastify = await initServer(t);267 for (let i = 0; i < 10; i++) {268 await seed.entidades.pergunta({ titulo: `titulo ${i}`, upvotes: i });269 }270 const options = { skip: 2, limit: 4 };271 const { statusCode, payload } = await fastify.inject({272 url: `/api/perguntas/trending?${utils.serialize(options)}`,273 method: 'GET',274 });275 const { elements, total } = JSON.parse(payload);276 t.same(statusCode, 200);277 t.same(total, 4);278 const expectedTitulos = ['titulo 7', 'titulo 6', 'titulo 5', 'titulo 4'];279 elements.forEach(({ titulo }, index) => {280 t.same(titulo, expectedTitulos[index]);...

Full Screen

Full Screen

usuario.test.js

Source:usuario.test.js Github

copy

Full Screen

...4const path = require('path');5const { initServer, randomObjectId } = require('../../../test-helpers');6const seed = require('../../../../seed');7test('api.usuarios.signup', async t => {8 const fastify = await initServer(t);9 const usuarioData = seed.fixtures.usuario();10 const { statusCode } = await fastify.inject({11 url: '/api/usuarios/signup',12 method: 'POST',13 payload: usuarioData,14 });15 t.same(statusCode, 200);16 t.end();17});18test('api.usuarios.changePassword', async t => {19 const fastify = await initServer(t);20 const usuario = await seed.entidades.usuario();21 const { statusCode } = await fastify.inject({22 url: `/api/usuarios/change-password/${usuario._id}`,23 method: 'POST',24 payload: { password: 'passwordTeste123', newPassword: 'passwordTeste1234' },25 });26 t.same(statusCode, 200);27 t.end();28});29test('api.usuarios.changePassword: tenta alterar senha de um usuário inexistente', async t => {30 const fastify = await initServer(t);31 const { statusCode } = await fastify.inject({32 url: `/api/usuarios/change-password/${randomObjectId()}`,33 method: 'POST',34 payload: { password: 'passwordTeste123', newPassword: 'passwordTeste1234' },35 });36 t.same(statusCode, 404);37 t.end();38});39test('api.usuarios.changePassword: tenta alterar senha passando uma senha atual incorreta', async t => {40 const fastify = await initServer(t);41 const usuario = await seed.entidades.usuario({ password: 'passwordCorreta' });42 const { statusCode, payload } = await fastify.inject({43 url: `/api/usuarios/change-password/${usuario._id}`,44 method: 'POST',45 payload: { password: 'passwordIncorreta', newPassword: 'passwordTeste1234' },46 });47 const { message } = JSON.parse(payload);48 t.same(statusCode, 401);49 t.same(message, 'Senha incorreta');50 t.end();51});52test('api.usuarios.delete', async t => {53 const fastify = await initServer(t);54 const usuario = await seed.entidades.usuario();55 const { statusCode } = await fastify.inject({56 url: `/api/usuarios/${usuario._id}`,57 method: 'DELETE',58 });59 t.same(statusCode, 200);60 t.end();61});62test('api.usuarios.delete: passa id inválido', async t => {63 const fastify = await initServer(t);64 const { statusCode, payload } = await fastify.inject({65 url: `/api/usuarios/${randomObjectId()}`,66 method: 'DELETE',67 });68 const { message } = JSON.parse(payload);69 t.same(message, 'Not Found');70 t.same(statusCode, 404);71 t.end();72});73test('api.usuarios.findAll', async t => {74 const fastify = await initServer(t);75 await seed.entidades.usuario({ nome: 'usuario 1' });76 await seed.entidades.usuario({ nome: 'usuario 2' });77 const { statusCode } = await fastify.inject({78 url: '/api/usuarios',79 method: 'GET',80 });81 t.same(statusCode, 200);82 t.end();83});84test('api.usuarios.find', async t => {85 const fastify = await initServer(t);86 const usuario = await seed.entidades.usuario();87 const { statusCode } = await fastify.inject({88 url: `/api/usuarios/${usuario._id}`,89 method: 'GET',90 });91 t.same(statusCode, 200);92 t.end();93});94test('api.usuarios.find: passa id inválido', async t => {95 const fastify = await initServer(t);96 const { statusCode, payload } = await fastify.inject({97 url: `/api/usuarios/${randomObjectId()}`,98 method: 'GET',99 });100 const { message } = JSON.parse(payload);101 t.same(message, 'Not Found');102 t.same(statusCode, 404);103 t.end();104});105test('api.usuarios.update', async t => {106 const fastify = await initServer(t);107 const usuario = await seed.entidades.usuario();108 const alteracoes = { username: 'usuarioAtualizado' };109 const { statusCode } = await fastify.inject({110 url: `/api/usuarios/${usuario._id}`,111 method: 'POST',112 payload: alteracoes,113 });114 t.same(statusCode, 200);115 t.end();116});117test('api.usuarios.update: passa id inválido', async t => {118 const fastify = await initServer(t);119 const { statusCode, payload } = await fastify.inject({120 url: `/api/usuarios/${randomObjectId()}`,121 method: 'POST',122 payload: {},123 });124 const { message } = JSON.parse(payload);125 t.same(message, 'Usuário não encontrado');126 t.same(statusCode, 404);127 t.end();128});129test('api.usuarios.update: tenta alterar senha', async t => {130 const fastify = await initServer(t);131 const usuario = await seed.entidades.usuario();132 const alteracoes = { password: 'novaSenha' };133 const { statusCode, payload } = await fastify.inject({134 url: `/api/usuarios/${usuario._id}`,135 method: 'POST',136 payload: alteracoes,137 });138 const { message } = JSON.parse(payload);139 t.same(message, 'Não é possível alterar senha por esta API');140 t.same(statusCode, 400);141 t.end();142});143test('api.usuarios.update: tenta alterar a imagem de perfil', async t => {144 const fastify = await initServer(t);145 const usuario = await seed.entidades.usuario();146 const alteracoes = { imagemId: randomObjectId() };147 const { statusCode, payload } = await fastify.inject({148 url: `/api/usuarios/${usuario._id}`,149 method: 'POST',150 payload: alteracoes,151 });152 const { message } = JSON.parse(payload);153 t.same(message, 'Não é possível alterar imagem de perfil por esta API');154 t.same(statusCode, 400);155 t.end();156});157for (const loginMethod of ['username', 'email']) {158 test(`api.usuarios.login: loga por ${loginMethod}`, async t => {159 const fastify = await initServer(t);160 const usuarioData = seed.fixtures.usuario();161 await seed.entidades.usuario(usuarioData);162 const { statusCode } = await fastify.inject({163 url: '/api/usuarios/login',164 method: 'POST',165 payload: { [loginMethod]: usuarioData[loginMethod], password: usuarioData.password },166 });167 t.same(statusCode, 200);168 t.end();169 });170}171test('api.usuarios.login: tenta logar com username inválido', async t => {172 const fastify = await initServer(t);173 const { statusCode, payload } = await fastify.inject({174 url: '/api/usuarios/login',175 method: 'POST',176 payload: { username: 'invalido', password: 'invalida' },177 });178 const { message } = JSON.parse(payload);179 t.same(message, 'Not Found');180 t.same(statusCode, 404);181 t.end();182});183test('api.usuarios.login: tenta logar com senha inválida', async t => {184 const fastify = await initServer(t);185 const createdUsuario = await seed.entidades.usuario();186 const { statusCode, payload } = await fastify.inject({187 url: '/api/usuarios/login',188 method: 'POST',189 payload: { username: createdUsuario.username, password: 'invalida' },190 });191 const { message } = JSON.parse(payload);192 t.same(message, 'Unauthorized');193 t.same(statusCode, 401);194 t.end();195});196test('api.usuarios.logout', async t => {197 const fastify = await initServer(t);198 const usuarioData = seed.fixtures.usuario();199 const { statusCode: statusCode1, headers } = await fastify.inject({200 url: '/api/usuarios/signup',201 method: 'POST',202 payload: usuarioData,203 });204 t.same(statusCode1, 200);205 const { statusCode } = await fastify.inject({206 url: '/api/usuarios/logout',207 method: 'DELETE',208 headers: { cookie: headers['set-cookie'] },209 });210 t.same(statusCode, 200);211 t.end();212});213test('api.usuarios.logout: tenta fazer logout com session inválida', async t => {214 const fastify = await initServer(t);215 const { statusCode, payload } = await fastify.inject({216 url: '/api/usuarios/logout',217 method: 'DELETE',218 headers: { cookie: 'invalida' },219 });220 const { message } = JSON.parse(payload);221 t.same(message, 'Not Found');222 t.same(statusCode, 404);223 t.end();224});225test('api.usuarios.perguntas', async t => {226 const fastify = await initServer(t);227 const usuario = await seed.entidades.usuario();228 const pergunta = await seed.entidades.pergunta({ usuarioId: usuario._id });229 const { statusCode } = await fastify.inject({230 url: `/api/usuarios/perguntas/${pergunta._id}`,231 method: 'GET',232 });233 t.same(statusCode, 200);234 t.end();235});236test('api.usuarios.perguntas: passa id inválido', async t => {237 const fastify = await initServer(t);238 const { statusCode, payload } = await fastify.inject({239 url: `/api/usuarios/perguntas/${randomObjectId()}`,240 method: 'GET',241 });242 const { message } = JSON.parse(payload);243 t.same(message, 'Not Found');244 t.same(statusCode, 404);245 t.end();246});247test('api.usuarios.respostas', async t => {248 const fastify = await initServer(t);249 const usuario = await seed.entidades.usuario();250 const resposta = await seed.entidades.resposta({ usuarioId: usuario._id });251 const { statusCode } = await fastify.inject({252 url: `/api/usuarios/respostas/${resposta._id}`,253 method: 'GET',254 });255 t.same(statusCode, 200);256 t.end();257});258test('api.usuarios.respostas: passa id inválido', async t => {259 const fastify = await initServer(t);260 const { statusCode, payload } = await fastify.inject({261 url: `/api/usuarios/respostas/${randomObjectId()}`,262 method: 'GET',263 });264 const { message } = JSON.parse(payload);265 t.same(message, 'Not Found');266 t.same(statusCode, 404);267 t.end();268});269test('api.usuarios.upload', async t => {270 const fastify = await initServer(t);271 const filePath = path.join(__dirname, '../../../../seed/arquivos/test.jpg');272 const usuario = await seed.entidades.usuario();273 const {274 res: { statusCode },275 } = await supertest(fastify.server)276 .post(`/api/usuarios/${usuario._id}/upload`)277 .field('Content-Type', 'multipart/form-data')278 .attach('test', filePath);279 t.same(statusCode, 200);280 t.end();281});282test('api.usuarios.upload: passa id usuário inválido', async t => {283 const fastify = await initServer(t);284 const filePath = path.join(__dirname, '../../../../seed/arquivos/test.jpg');285 const {286 res: { statusCode, text },287 } = await supertest(fastify.server)288 .post(`/api/usuarios/${randomObjectId()}/upload`)289 .field('Content-Type', 'multipart/form-data')290 .attach('test', filePath);291 const { message } = JSON.parse(text);292 t.same(message, 'Referência para usuário inválida');293 t.same(statusCode, 404);294 t.end();295});296test('api.usuarios.upload: requisição não multipart', async t => {297 const fastify = await initServer(t);298 const usuario = await seed.entidades.usuario();299 const {300 res: { statusCode, text },301 } = await supertest(fastify.server).post(`/api/usuarios/${usuario._id}/upload`);302 const { error } = JSON.parse(text);303 t.same(error, 'the request is not multipart');304 t.same(statusCode, 400);305 t.end();...

Full Screen

Full Screen

resposta.test.js

Source:resposta.test.js Github

copy

Full Screen

...10 });11 return headers['set-cookie'];12};13test('api.respostas.create', async t => {14 const fastify = await initServer(t);15 const { _id: usuarioId } = await seed.entidades.usuario();16 const { _id: perguntaId } = await seed.entidades.pergunta({ usuarioId });17 const respostaData = seed.fixtures.resposta({ usuarioId: usuarioId.toString(), perguntaId: perguntaId.toString() });18 const { statusCode } = await fastify.inject({19 url: '/api/respostas',20 method: 'POST',21 payload: respostaData,22 });23 t.same(statusCode, 200);24 t.end();25});26test('api.respostas.create: cadastra com referência para usuário inválida', async t => {27 const fastify = await initServer(t);28 const usuarioId = randomObjectId();29 const { _id: perguntaId } = await seed.entidades.pergunta();30 const respostaData = seed.fixtures.resposta({ usuarioId: usuarioId.toString(), perguntaId: perguntaId.toString() });31 const { statusCode, payload } = await fastify.inject({32 url: '/api/respostas',33 method: 'POST',34 payload: respostaData,35 });36 const { message } = JSON.parse(payload);37 t.same(message, 'Referência para usuário inválida');38 t.same(statusCode, 400);39 t.end();40});41test('api.respostas.create: cadastra com referência para pergunta inválida', async t => {42 const fastify = await initServer(t);43 const perguntaId = randomObjectId();44 const { _id: usuarioId } = await seed.entidades.usuario();45 const respostaData = seed.fixtures.resposta({ usuarioId: usuarioId.toString(), perguntaId: perguntaId.toString() });46 const { statusCode, payload } = await fastify.inject({47 url: '/api/respostas',48 method: 'POST',49 payload: respostaData,50 });51 const { message } = JSON.parse(payload);52 t.same(message, 'Referência para pergunta inválida');53 t.same(statusCode, 400);54 t.end();55});56test('api.respostas.delete', async t => {57 const fastify = await initServer(t);58 const usuario = seed.fixtures.usuario();59 const { _id: usuarioId } = await seed.entidades.usuario(usuario);60 const resposta = await seed.entidades.resposta({ usuarioId });61 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });62 const { statusCode } = await fastify.inject({63 url: `/api/respostas/${resposta._id}`,64 method: 'DELETE',65 headers: { cookie },66 });67 t.same(statusCode, 200);68 t.end();69});70test('api.respostas.delete: passa id inválido', async t => {71 const fastify = await initServer(t);72 const { statusCode, payload } = await fastify.inject({73 url: `/api/respostas/${randomObjectId()}`,74 method: 'DELETE',75 });76 const { message } = JSON.parse(payload);77 t.same(message, 'Not Found');78 t.same(statusCode, 404);79 t.end();80});81test('api.respostas.update: somente usuario que postou a resposta pode deletá-la', async t => {82 const fastify = await initServer(t);83 const usuario1 = await seed.entidades.usuario();84 const usuario2 = seed.fixtures.usuario();85 await seed.entidades.usuario(usuario2);86 const resposta = await seed.entidades.resposta({ usuarioId: usuario1._id });87 const cookie = await getCookie({ fastify, payload: { username: usuario2.username, password: usuario2.password } });88 const { statusCode, payload } = await fastify.inject({89 url: `/api/respostas/${resposta._id}`,90 method: 'DELETE',91 headers: { cookie },92 });93 const { message } = JSON.parse(payload);94 t.same(message, 'Somente o usuário que postou a resposta pode deletá-la');95 t.same(statusCode, 401);96 t.end();97});98test('api.respostas.findAll', async t => {99 const fastify = await initServer(t);100 await seed.entidades.resposta({ nome: 'resposta 1' });101 await seed.entidades.resposta({ nome: 'resposta 2' });102 const { statusCode } = await fastify.inject({103 url: '/api/respostas',104 method: 'GET',105 });106 t.same(statusCode, 200);107 t.end();108});109test('api.respostas.find', async t => {110 const fastify = await initServer(t);111 const resposta = await seed.entidades.resposta();112 const { statusCode } = await fastify.inject({113 url: `/api/respostas/${resposta._id}`,114 method: 'GET',115 });116 t.same(statusCode, 200);117 t.end();118});119test('api.respostas.find: passa id inválido', async t => {120 const fastify = await initServer(t);121 const { statusCode, payload } = await fastify.inject({122 url: `/api/respostas/${randomObjectId()}`,123 method: 'GET',124 });125 const { message } = JSON.parse(payload);126 t.same(message, 'Not Found');127 t.same(statusCode, 404);128 t.end();129});130test('api.respostas.update', async t => {131 const fastify = await initServer(t);132 const usuario = seed.fixtures.usuario();133 const { _id: usuarioId } = await seed.entidades.usuario(usuario);134 const resposta = await seed.entidades.resposta({ usuarioId });135 const alteracoes = { descricao: 'resposta atualizado' };136 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });137 const { statusCode } = await fastify.inject({138 url: `/api/respostas/${resposta._id}`,139 method: 'POST',140 payload: alteracoes,141 headers: { cookie },142 });143 t.same(statusCode, 200);144 t.end();145});146test('api.respostas.update: passa id inválido', async t => {147 const fastify = await initServer(t);148 const { statusCode, payload } = await fastify.inject({149 url: `/api/respostas/${randomObjectId()}`,150 method: 'POST',151 payload: {},152 });153 const { message } = JSON.parse(payload);154 t.same(message, 'Not Found');155 t.same(statusCode, 404);156 t.end();157});158test('api.respostas.update: tenta atualizar usuarioId', async t => {159 const fastify = await initServer(t);160 const usuario = seed.fixtures.usuario();161 const { _id: usuarioId } = await seed.entidades.usuario(usuario);162 const resposta = await seed.entidades.resposta({ usuarioId });163 const alteracoes = { usuarioId: 'nao pode migao' };164 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });165 const { statusCode, payload } = await fastify.inject({166 url: `/api/respostas/${resposta._id}`,167 method: 'POST',168 payload: alteracoes,169 headers: { cookie },170 });171 const { message } = JSON.parse(payload);172 t.same(message, 'Referência de usuário da resposta não deve ser alterada');173 t.same(statusCode, 400);174 t.end();175});176test('api.respostas.update: somente usuario que postou a resposta pode editá-la', async t => {177 const fastify = await initServer(t);178 const usuario1 = await seed.entidades.usuario();179 const usuario2 = seed.fixtures.usuario();180 await seed.entidades.usuario(usuario2);181 const resposta = await seed.entidades.resposta({ usuarioId: usuario1._id });182 const alteracoes = { descricao: 'resposta atualizado' };183 const cookie = await getCookie({ fastify, payload: { username: usuario2.username, password: usuario2.password } });184 const { statusCode, payload } = await fastify.inject({185 url: `/api/respostas/${resposta._id}`,186 method: 'POST',187 payload: alteracoes,188 headers: { cookie },189 });190 const { message } = JSON.parse(payload);191 t.same(message, 'Somente o usuário que postou a resposta pode editá-la');192 t.same(statusCode, 401);193 t.end();194});195test('api.respostas.perguntas', async t => {196 const fastify = await initServer(t);197 const pergunta = await seed.entidades.pergunta();198 await seed.entidades.resposta({ perguntaId: pergunta._id });199 const { statusCode } = await fastify.inject({200 url: `/api/respostas/perguntas/${pergunta._id}`,201 method: 'GET',202 });203 t.same(statusCode, 200);204 t.end();205});206test('api.respostas.usuarios', async t => {207 const fastify = await initServer(t);208 await seed.entidades.pergunta();209 const usuario = await seed.entidades.usuario();210 await seed.entidades.resposta({ usuarioId: usuario._id });211 const { statusCode } = await fastify.inject({212 url: `/api/respostas/usuarios/${usuario._id}`,213 method: 'GET',214 });215 t.same(statusCode, 200);216 t.end();...

Full Screen

Full Screen

votes.test.js

Source:votes.test.js Github

copy

Full Screen

...10 });11 return headers['set-cookie'];12};13test('api.votes.upvote', async t => {14 const fastify = await initServer(t);15 const usuario = seed.fixtures.usuario();16 const { _id: usuarioId } = await seed.entidades.usuario(usuario);17 const { _id: perguntaId } = await seed.entidades.pergunta({ usuarioId });18 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });19 const { statusCode } = await fastify.inject({20 url: `/api/posts/${perguntaId}/upvote`,21 method: 'GET',22 headers: { cookie },23 });24 const perguntaAtualizada = await fastify.core.models.pergunta.find({ _id: perguntaId });25 t.same(statusCode, 200);26 t.same(perguntaAtualizada.upvotes, 1);27 t.end();28});29test('api.votes.upvote: exception', async t => {30 const fastify = await initServer(t);31 const { _id: perguntaId } = await seed.entidades.pergunta();32 const { statusCode, payload } = await fastify.inject({33 url: `/api/posts/${perguntaId}/upvote`,34 method: 'GET',35 });36 const { message } = JSON.parse(payload);37 t.same(statusCode, 400);38 t.same(message, 'Error: Referência para usuário inválida');39 t.end();40});41test('api.votes.downvote', async t => {42 const fastify = await initServer(t);43 const usuario = seed.fixtures.usuario();44 const { _id: usuarioId } = await seed.entidades.usuario(usuario);45 const { _id: perguntaId } = await seed.entidades.pergunta({ usuarioId });46 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });47 const { statusCode } = await fastify.inject({48 url: `/api/posts/${perguntaId}/downvote`,49 method: 'GET',50 headers: { cookie },51 });52 const perguntaAtualizada = await fastify.core.models.pergunta.find({ _id: perguntaId });53 t.same(statusCode, 200);54 t.same(perguntaAtualizada.downvotes, 1);55 t.end();56});57test('api.votes.downvote: exception', async t => {58 const fastify = await initServer(t);59 const { _id: perguntaId } = await seed.entidades.pergunta();60 const { statusCode, payload } = await fastify.inject({61 url: `/api/posts/${perguntaId}/downvote`,62 method: 'GET',63 });64 const { message } = JSON.parse(payload);65 t.same(statusCode, 400);66 t.same(message, 'Error: Referência para usuário inválida');67 t.end();68});69test('api.votes.unvote', async t => {70 const fastify = await initServer(t);71 const usuario = seed.fixtures.usuario();72 const { _id: usuarioId } = await seed.entidades.usuario(usuario);73 const { _id: perguntaId } = await seed.entidades.pergunta({ usuarioId });74 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });75 await fastify.core.models.votes.upvote({ postId: perguntaId, usuarioId });76 const { statusCode } = await fastify.inject({77 url: `/api/posts/${perguntaId}/unvote`,78 method: 'DELETE',79 headers: { cookie },80 });81 const perguntaAtualizada = await fastify.core.models.pergunta.find({ _id: perguntaId });82 t.same(statusCode, 200);83 t.same(perguntaAtualizada.upvotes, 0);84 t.end();85});86test('api.votes.unvote: exception', async t => {87 const fastify = await initServer(t);88 const { _id: perguntaId } = await seed.entidades.pergunta();89 const { statusCode, payload } = await fastify.inject({90 url: `/api/posts/${perguntaId}/unvote`,91 method: 'DELETE',92 });93 const { message } = JSON.parse(payload);94 t.same(statusCode, 400);95 t.same(message, 'Error: Documento "Vote" não encontrado');96 t.end();97});98test('api.votes.find', async t => {99 const fastify = await initServer(t);100 const usuario = seed.fixtures.usuario();101 const { _id: usuarioId } = await seed.entidades.usuario(usuario);102 const { _id: perguntaId } = await seed.entidades.pergunta({ usuarioId });103 const cookie = await getCookie({ fastify, payload: { username: usuario.username, password: usuario.password } });104 await fastify.core.models.votes.upvote({ postId: perguntaId, usuarioId });105 const { statusCode, payload } = await fastify.inject({106 url: `/api/posts/${perguntaId}/vote`,107 method: 'GET',108 headers: { cookie },109 });110 const { total } = JSON.parse(payload);111 t.same(statusCode, 200);112 t.same(total, 1);113 t.end();114});115test('api.votes.find: chama a api sem cookie', async t => {116 const fastify = await initServer(t);117 const usuario = seed.fixtures.usuario();118 const { _id: usuarioId } = await seed.entidades.usuario(usuario);119 const { _id: perguntaId } = await seed.entidades.pergunta({ usuarioId });120 await fastify.core.models.votes.upvote({ postId: perguntaId, usuarioId });121 const { statusCode, payload } = await fastify.inject({122 url: `/api/posts/${perguntaId}/vote`,123 method: 'GET',124 });125 const { total } = JSON.parse(payload);126 t.same(statusCode, 200);127 t.same(total, 0);128 t.end();...

Full Screen

Full Screen

me.tests.js

Source:me.tests.js Github

copy

Full Screen

...6import me from '../../../server/routes/me';7import ScriptManager from '../../../server/lib/scriptmanager';8import { user } from '../../utils/dummyData';9import * as constants from '../../../server/constants';10function initServer(script, newUser) {11 const storage = {12 read: () => Promise.resolve(storage.data),13 data: {14 scripts: {15 memberships: script && script.toString()16 }17 }18 };19 const app = express();20 const theUser = newUser || user;21 app.use('/me', (req, res, next) => { req.user = theUser; next(); }, me(new ScriptManager(storage)));22 return app;23}24describe('# /me', () => {25 it('should return default is script is not defined', (done) => {26 const app = initServer();27 request(app)28 .get('/me')29 .expect(200)30 .end((err, res) => {31 if (err) {32 return done(err);33 }34 expect(res.body.createMemberships).toEqual(false);35 expect(res.body.memberships).toEqual([]);36 expect(res.body.role).toEqual(1);37 return done();38 });39 });40 it('should return default if script fails', (done) => {41 const app = initServer('(ctx, cb) => cb(new Error("foo"))');42 request(app)43 .get('/me')44 .expect(200)45 .end((err, res) => {46 if (err) {47 return done(err);48 }49 expect(res.body.createMemberships).toEqual(false);50 expect(res.body.memberships).toEqual([]);51 expect(res.body.role).toEqual(1);52 return done();53 });54 });55 it('should support scripts that return an array', (done) => {56 const script = '(ctx, cb) => cb(null, [ "IT", "Finance" ])';57 const app = initServer(script);58 request(app)59 .get('/me')60 .expect(200)61 .end((err, res) => {62 if (err) {63 return done(err);64 }65 expect(res.body.createMemberships).toEqual(false);66 expect(res.body.memberships.length).toEqual(2);67 expect(res.body.memberships[1]).toEqual('Finance');68 expect(res.body.role).toEqual(1);69 return done();70 });71 });72 it('should support scripts that return an object', (done) => {73 const script = '(ctx, cb) => cb(null, { memberships: [ "IT", "Finance" ] })';74 const app = initServer(script);75 request(app)76 .get('/me')77 .expect(200)78 .end((err, res) => {79 if (err) {80 return done(err);81 }82 expect(res.body.createMemberships).toEqual(false);83 expect(res.body.memberships.length).toEqual(2);84 expect(res.body.memberships[1]).toEqual('Finance');85 expect(res.body.role).toEqual(1);86 return done();87 });88 });89 it('should support scripts that return an object with createMemberships', (done) => {90 const script = '(ctx, cb) => cb(null, { createMemberships: true, memberships: [ "IT", "Finance" ] })';91 const app = initServer(script);92 request(app)93 .get('/me')94 .expect(200)95 .end((err, res) => {96 if (err) {97 return done(err);98 }99 expect(res.body.createMemberships).toEqual(true);100 expect(res.body.memberships.length).toEqual(2);101 expect(res.body.memberships[1]).toEqual('Finance');102 expect(res.body.role).toEqual(1);103 return done();104 });105 });106 it('check role 2', (done) => {107 const newUser = _.cloneDeep(user);108 newUser.scope += ` ${constants.ADMIN_PERMISSION}`;109 const app = initServer(undefined, newUser);110 request(app)111 .get('/me')112 .expect(200)113 .end((err, res) => {114 if (err) {115 return done(err);116 }117 expect(res.body.role).toEqual(2);118 return done();119 });120 });...

Full Screen

Full Screen

server.js

Source:server.js Github

copy

Full Screen

...12const terminal_1 = __importDefault(require("./terminal"));13const common_1 = __importDefault(require("./common"));14const hook_1 = __importDefault(require("./hook"));15exports.sockets = new Map();16async function initServer() {17 await cypher_1.default.ready;18 const domain = `websync-${config_1.username}-${cypher_1.default.hash.substr(16, 15)}.nodesite.eu`;19 terminal_1.default.write(chalk_1.default.green(chalk_1.default.green('\r\n\nOthers can join this session using\r\n')));20 terminal_1.default.write(chalk_1.default.red(`npx nodesite-dirsync join ${domain}\r\n\n`));21 nodesite_eu_1.NodeSiteClient.create(domain, '/', () => ({22 statusCode: 302,23 head: {24 Location: 'https://nodesite.eu/',25 },26 }));27 nodesite_eu_1.NodeSiteClient.io((socket, site) => {28 socket.on('message', async (message) => {29 if (typeof message !== 'string')30 return;...

Full Screen

Full Screen

imagem.test.js

Source:imagem.test.js Github

copy

Full Screen

1'use strict';2const { test } = require('tap');3const { initServer, randomObjectId } = require('../../../test-helpers');4test('api.imagem.find', async t => {5 const fastify = await initServer(t);6 const { payload } = await fastify.inject({7 url: '/api/imagem',8 method: 'POST',9 payload: { nome: 'teste', data: 'data' },10 });11 const { elements } = JSON.parse(payload);12 const { statusCode } = await fastify.inject({13 url: '/api/imagem/' + elements[0]._id,14 method: 'GET',15 });16 t.same(statusCode, 200);17 t.end();18});19test('api.imagem.find', async t => {20 const fastify = await initServer(t);21 const { payload } = await fastify.inject({22 url: '/api/imagem/nome/a',23 method: 'GET',24 });25 const { message, statusCode } = JSON.parse(payload);26 t.same(message, 'Not Found');27 t.same(statusCode, 404);28 t.end();29});30test('api.imagem.find', async t => {31 const fastify = await initServer(t);32 const { payload } = await fastify.inject({33 url: '/api/imagem/' + randomObjectId(),34 method: 'GET',35 });36 const { message, statusCode } = JSON.parse(payload);37 t.same(message, 'Not Found');38 t.same(statusCode, 404);39 t.end();40});41test('api.imagem.delete', async t => {42 const fastify = await initServer(t);43 const { payload } = await fastify.inject({44 url: '/api/imagem',45 method: 'POST',46 payload: { nome: 'teste', data: 'data' },47 });48 const { elements } = JSON.parse(payload);49 const { statusCode } = await fastify.inject({50 url: '/api/imagem/' + elements[0]._id,51 method: 'DELETE',52 });53 t.same(statusCode, 200);54 t.end();55});56test('api.imagem.delete', async t => {57 const fastify = await initServer(t);58 const { statusCode, payload } = await fastify.inject({59 url: '/api/imagem/' + randomObjectId(),60 method: 'DELETE',61 });62 const { message } = JSON.parse(payload);63 t.same(message, 'Not Found');64 t.same(statusCode, 404);65 t.end();...

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('playwright-core/lib/server/initServer');2const { chromium } = require('playwright-core');3(async () => {4 const server = await initServer();5 const browser = await chromium.connect({6 wsEndpoint: server.wsEndpoint(),7 });8 const page = await browser.newPage();9 await page.screenshot({ path: `example.png` });10 await browser.close();11 await server.close();12})();13### initServer(options)14#### server.wsEndpoint()15#### server.close()

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('playwright-core/lib/server/initServer');2const { chromium } = require('playwright-core');3(async () => {4 const server = await initServer();5 const browser = await chromium.connect({6 wsEndpoint: server.wsEndpoint(),7 });8 const page = await browser.newPage();9 await page.screenshot({ path: `example.png` });10 await browser.close();11 await server.close();12})();13### initServer(options)14#### server.wsEndpoint()15#### server.close()16Whether to run browsers in headlplaywright-test/lib/server');17(async () => {18 const server = await initServer();19 const { host, port } = server.address();20})();21### `initServer(options)`

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('@playwright/test');2const { createServer } = require('http');3const { parse } = require('url');4const server = createServer((req, res) => {5 const { query } = parse(req.url, true);6 const { status, body } = query;7 res.statusCode = status;8 res.end(body);9});10test('test', async ({ page }) => {11 const { port } = await initServer(server);12});13### `initServer(server: http.Server, options?: { host?: string }): Promise<{ port: number, host: string, close: () => Promise<void> }>`

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('@playwright/test/lib/server/initServer');2const { Playwright } = require('@playwright/test');3const playwright = new Playwright();4const server = await initServer(playwright, {5 viewport: { width: 1280, height: 720 },6 launchOptions: {7 },8});9const browser = await playwright.chromium.launch({10});11const context = await browser.newContext();12const page = await context.newPage();13await page.screenshot({ path: 'google.png' });14await browser.close();15await server.close();

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('playwright-core/lib/server/server');2(async () => {3 const server = await initServer();4 await server.listen(8080);5 await server.close();6})();

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('playwright/lib/server/server');2const { chromium } = require('playwright');3const path = require('path');4const server = await initServer();5const context = await chromium.launchPersistentContext(path.join(__dirname, 'playwright-data'), {6 args: [`--remote-debugging-port=${server.port}`]7});8const page = await context.newPage();9### `initServer()`10### `Server.listen(port)`11### `Server.close()`12### `Server.setHandler(handler)`13### `Request.url()`14### `Request.method()`15### `Request.headers()`16### `Request.postData()`17### `Request.postDataBuffer()`18### `Request.postDataJSON()`19### `Request.postDataText()`20### `Request.postDataParams()`21### `Request.postDataMultiPart()`22### `Request.postDataFile()`23### `Request.postDataFile()`24### `Response.status()`25### `Response.statusText()`26### `Response.headers()`27### `Response.body()`28### `Response.bodyBuffer()`29### `Response.bodyJSON()`30### `Response.bodyText()`

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('playwright/lib/server/server');2const { chromium } = require('playwright');3const path = require('path');4const server = await initServer();5const context = await chromium.launchPersistentContext(path.join(__dirname, 'playwright-data'), {6 args: [`--remote-debugging-port=${server.port}`]7});8const page = await context.newPage();

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { initServer } = require('playwright/lib/server/server');2initServer();3const { initServer } = require('playwright');4initServer();5const { connect } = require('playwright');6connect();7const { initServer } = require('playwright');8initServer({ browsers: ['firefox', 'webkit'] });9const { initServer } = require('playwright');10initServer({ port: 8081 });

Full Screen

Full Screen

Playwright tutorial

LambdaTest’s Playwright tutorial will give you a broader idea about the Playwright automation framework, its unique features, and use cases with examples to exceed your understanding of Playwright testing. This tutorial will give A to Z guidance, from installing the Playwright framework to some best practices and advanced concepts.

Chapters:

  1. What is Playwright : Playwright is comparatively new but has gained good popularity. Get to know some history of the Playwright with some interesting facts connected with it.
  2. How To Install Playwright : Learn in detail about what basic configuration and dependencies are required for installing Playwright and run a test. Get a step-by-step direction for installing the Playwright automation framework.
  3. Playwright Futuristic Features: Launched in 2020, Playwright gained huge popularity quickly because of some obliging features such as Playwright Test Generator and Inspector, Playwright Reporter, Playwright auto-waiting mechanism and etc. Read up on those features to master Playwright testing.
  4. What is Component Testing: Component testing in Playwright is a unique feature that allows a tester to test a single component of a web application without integrating them with other elements. Learn how to perform Component testing on the Playwright automation framework.
  5. Inputs And Buttons In Playwright: Every website has Input boxes and buttons; learn about testing inputs and buttons with different scenarios and examples.
  6. Functions and Selectors in Playwright: Learn how to launch the Chromium browser with Playwright. Also, gain a better understanding of some important functions like “BrowserContext,” which allows you to run multiple browser sessions, and “newPage” which interacts with a page.
  7. Handling Alerts and Dropdowns in Playwright : Playwright interact with different types of alerts and pop-ups, such as simple, confirmation, and prompt, and different types of dropdowns, such as single selector and multi-selector get your hands-on with handling alerts and dropdown in Playright testing.
  8. Playwright vs Puppeteer: Get to know about the difference between two testing frameworks and how they are different than one another, which browsers they support, and what features they provide.
  9. Run Playwright Tests on LambdaTest: Playwright testing with LambdaTest leverages test performance to the utmost. You can run multiple Playwright tests in Parallel with the LammbdaTest test cloud. Get a step-by-step guide to run your Playwright test on the LambdaTest platform.
  10. Playwright Python Tutorial: Playwright automation framework support all major languages such as Python, JavaScript, TypeScript, .NET and etc. However, there are various advantages to Python end-to-end testing with Playwright because of its versatile utility. Get the hang of Playwright python testing with this chapter.
  11. Playwright End To End Testing Tutorial: Get your hands on with Playwright end-to-end testing and learn to use some exciting features such as TraceViewer, Debugging, Networking, Component testing, Visual testing, and many more.
  12. Playwright Video Tutorial: Watch the video tutorials on Playwright testing from experts and get a consecutive in-depth explanation of Playwright automation testing.

Run Playwright Internal automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful