Skip to content

Commit c8c88f6

Browse files
committed
Use logger instead of getLogger
- Removes PLog module
1 parent 6c98a16 commit c8c88f6

21 files changed

+105
-113
lines changed

spec/Subscription.spec.js

Lines changed: 9 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
var Subscription = require('../src/LiveQuery/Subscription').Subscription;
2+
let logger;
23
describe('Subscription', function() {
34

45
beforeEach(function() {
5-
var mockError = jasmine.createSpy('error');
6-
//spyOn(PLog, 'error').and.callThrough();
7-
jasmine.mockLibrary('../src/LiveQuery/PLog', 'error', mockError);
6+
logger = require('../src/logging').logger;
7+
spyOn(logger, 'error').and.callThrough();
88
});
99

10-
xit('can be initialized', function() {
10+
it('can be initialized', function() {
1111
var subscription = new Subscription('className', { key : 'value' }, 'hash');
1212

1313
expect(subscription.className).toBe('className');
@@ -62,17 +62,15 @@ describe('Subscription', function() {
6262
var subscription = new Subscription('className', { key : 'value' }, 'hash');
6363
subscription.deleteClientSubscription(1, 1);
6464

65-
var PLog =require('../src/LiveQuery/PLog');
66-
expect(PLog.error).toHaveBeenCalled();
65+
expect(logger.error).toHaveBeenCalled();
6766
});
6867

6968
it('can delete nonexistent request for one client', function() {
7069
var subscription = new Subscription('className', { key : 'value' }, 'hash');
7170
subscription.addClientSubscription(1, 1);
7271
subscription.deleteClientSubscription(1, 2);
7372

74-
var PLog =require('../src/LiveQuery/PLog');
75-
expect(PLog.error).toHaveBeenCalled();
73+
expect(logger.error).toHaveBeenCalled();
7674
expect(subscription.clientRequestIds.size).toBe(1);
7775
expect(subscription.clientRequestIds.get(1)).toEqual([1]);
7876
});
@@ -83,8 +81,7 @@ describe('Subscription', function() {
8381
subscription.addClientSubscription(1, 2);
8482
subscription.deleteClientSubscription(1, 2);
8583

86-
var PLog =require('../src/LiveQuery/PLog');
87-
expect(PLog.error).not.toHaveBeenCalled();
84+
expect(logger.error).not.toHaveBeenCalled();
8885
expect(subscription.clientRequestIds.size).toBe(1);
8986
expect(subscription.clientRequestIds.get(1)).toEqual([1]);
9087
});
@@ -96,8 +93,7 @@ describe('Subscription', function() {
9693
subscription.deleteClientSubscription(1, 1);
9794
subscription.deleteClientSubscription(1, 2);
9895

99-
var PLog =require('../src/LiveQuery/PLog');
100-
expect(PLog.error).not.toHaveBeenCalled();
96+
expect(logger.error).not.toHaveBeenCalled();
10197
expect(subscription.clientRequestIds.size).toBe(0);
10298
});
10399

@@ -111,13 +107,8 @@ describe('Subscription', function() {
111107
subscription.deleteClientSubscription(2, 1);
112108
subscription.deleteClientSubscription(2, 2);
113109

114-
var PLog =require('../src/LiveQuery/PLog');
115-
expect(PLog.error).not.toHaveBeenCalled();
110+
expect(logger.error).not.toHaveBeenCalled();
116111
expect(subscription.clientRequestIds.size).toBe(1);
117112
expect(subscription.clientRequestIds.get(1)).toEqual([1]);
118113
});
119-
120-
afterEach(function(){
121-
jasmine.restoreLibrary('../src/LiveQuery/PLog', 'error');
122-
});
123114
});

src/Adapters/Logger/WinstonLogger.js

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ function updateTransports(options) {
3636
}, options));
3737
}
3838
}
39-
// Mount the additiona transports
39+
// Mount the additional transports
4040
additionalTransports.forEach((transport) => {
4141
transports[transport.name] = transport;
4242
});
@@ -45,7 +45,16 @@ function updateTransports(options) {
4545
});
4646
}
4747

48-
export function configureLogger({ logsFolder, jsonLogs, logLevel = winston.level } = defaults) {
48+
export function configureLogger({
49+
logsFolder = defaults.logsFolder,
50+
jsonLogs = defaults.jsonLogs,
51+
logLevel = winston.level,
52+
verbose = defaults.verbose } = {}) {
53+
54+
if (verbose) {
55+
logLevel = 'verbose';
56+
}
57+
4958
winston.level = logLevel;
5059
const options = {};
5160

src/Adapters/Logger/WinstonLoggerAdapter.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,9 @@ let _getNearestDay = (date) => {
1111
export class WinstonLoggerAdapter extends LoggerAdapter {
1212
constructor(options) {
1313
super();
14-
configureLogger(options);
14+
if (options) {
15+
configureLogger(options);
16+
}
1517
}
1618

1719
info() {

src/Adapters/Storage/Mongo/MongoTransform.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import getLogger from '../../../logging';
1+
import logger from '../../../logging';
22
import _ from 'lodash';
33
var mongodb = require('mongodb');
44
var Parse = require('parse/node').Parse;
@@ -749,11 +749,11 @@ const mongoObjectToParseObject = (className, mongoObject, schema) => {
749749
if (key.indexOf('_p_') == 0) {
750750
var newKey = key.substring(3);
751751
if (!schema.fields[newKey]) {
752-
getLogger().info('transform.js', 'Found a pointer column not in the schema, dropping it.', className, newKey);
752+
logger.info('transform.js', 'Found a pointer column not in the schema, dropping it.', className, newKey);
753753
break;
754754
}
755755
if (schema.fields[newKey].type !== 'Pointer') {
756-
getLogger().info('transform.js', 'Found a pointer in a non-pointer column, dropping it.', className, key);
756+
logger.info('transform.js', 'Found a pointer in a non-pointer column, dropping it.', className, key);
757757
break;
758758
}
759759
if (mongoObject[key] === null) {

src/Controllers/HooksController.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import * as DatabaseAdapter from "../DatabaseAdapter";
44
import * as triggers from "../triggers";
55
import * as Parse from "parse/node";
66
import * as request from "request";
7-
import getLogger from '../logging';
7+
import logger from '../logging';
88

99
const DefaultHooksCollectionName = "_Hooks";
1010

@@ -181,7 +181,7 @@ function wrapToHTTPRequest(hook, key) {
181181
if (key) {
182182
jsonRequest.headers['X-Parse-Webhook-Key'] = key;
183183
} else {
184-
getLogger().warn('Making outgoing webhook request without webhookKey being set!');
184+
logger.warn('Making outgoing webhook request without webhookKey being set!');
185185
}
186186

187187
request.post(hook.url, jsonRequest, function (err, httpResponse, body) {

src/LiveQuery/Client.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import Parse from 'parse/node';
2-
import getLogger from '../logging';
2+
import logger from '../logging';
33

44
import type { FlattenedObjectData } from './Subscription';
55
export type Message = { [attr: string]: any };
@@ -37,7 +37,7 @@ class Client {
3737
}
3838

3939
static pushResponse(parseWebSocket: any, message: Message): void {
40-
getLogger().verbose('Push Response : %j', message);
40+
logger.verbose('Push Response : %j', message);
4141
parseWebSocket.send(message);
4242
}
4343

src/LiveQuery/PLog.js

Lines changed: 0 additions & 4 deletions
This file was deleted.

src/LiveQuery/ParseCloudCodePublisher.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { ParsePubSub } from './ParsePubSub';
2-
import getLogger from '../logging';
2+
import logger from '../logging';
33

44
class ParseCloudCodePublisher {
55
parsePublisher: Object;
@@ -20,7 +20,7 @@ class ParseCloudCodePublisher {
2020

2121
// Request is the request object from cloud code functions. request.object is a ParseObject.
2222
_onCloudCodeMessage(type: string, request: any): void {
23-
getLogger().verbose('Raw request from cloud code current : %j | original : %j', request.object, request.original);
23+
logger.verbose('Raw request from cloud code current : %j | original : %j', request.object, request.original);
2424
// We need the full JSON which includes className
2525
let message = {
2626
currentParseObject: request.object._toFullJSON()

0 commit comments

Comments
 (0)