// Copyright 2019, Google LLC.

// Licensed under the Apache License, Version 2.0 (the "License");

// you may not use this file except in compliance with the License.

// You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing, software

// distributed under the License is distributed on an "AS IS" BASIS,

// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

// See the License for the specific language governing permissions and

// limitations under the License.

// NOTE:

// This app can only be fully tested when deployed, because

// Pub/Sub requires a live endpoint URL to hit. Nevertheless,

// these tests mock it and partially test it locally.

'use strict';

const assert = require('assert');

const path = require('path');

const supertest = require('supertest');

const sinon = require('sinon');

const uuid = require('uuid');

let request;

describe('Unit Tests', () => {

before(() => {

const app = require(path.join(__dirname, '..', 'app'));

request = supertest(app);

});

describe('should fail', () => {

it(`on a Bad Request with an empty payload`, async () => {

await request.post('/').type('json').send('').expect(400);

});

it(`on a Bad Request with an invalid payload`, async () => {

await request

.post('/')

.type('json')

.send({nomessage: 'invalid'})

.expect(400);

});

it(`on a Bad Request with an invalid mimetype`, async () => {

await request.post('/').type('text').send('{message: true}').expect(400);

});

});

describe('should succeed', () => {

beforeEach(() => {

sinon.spy(console, 'error');

sinon.spy(console, 'log');

});

afterEach(() => {

console.error.restore();

console.log.restore();

});

it(`with a minimally valid Pub/Sub Message`, async () => {

await request

.post('/')

.type('json')

.send({message: true})

.expect(204)

.expect(() => assert.ok(console.log.calledWith('Hello World!')));

});

it(`with a populated Pub/Sub Message`, async () => {

const name = uuid.v4();

const data = Buffer.from(name).toString(`base64`);

await request

.post('/')

.type('json')

.send({message: {data}})

.expect(204)

.expect(() => assert.ok(console.log.calledWith(`Hello ${name}!`)));

});

});

});