Socket
Socket
Sign inDemoInstall

@bugsnag/delivery-expo

Package Overview
Dependencies
Maintainers
7
Versions
79
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@bugsnag/delivery-expo - npm Package Compare versions

Comparing version 6.4.1 to 7.0.0-alpha.0

48

delivery.js

@@ -22,6 +22,6 @@ const payload = require('@bugsnag/core/lib/json-payload')

const logError = e => client._logger.error('Error redelivering payload', e)
const logError = e => client.__logger.error('Error redelivering payload', e)
const enqueue = async (payloadKind, failedPayload) => {
client._logger.info(`Writing ${payloadKind} payload to cache`)
client.__logger.info(`Writing ${payloadKind} payload to cache`)
await queues[payloadKind].enqueue(failedPayload, logError)

@@ -32,3 +32,3 @@ if (networkStatus.isConnected) queueConsumers[payloadKind].start()

const onerror = async (err, failedPayload, payloadKind, cb) => {
client._logger.error(`${payloadKind} failed to send…\n${(err && err.stack) ? err.stack : err}`, err)
client.__logger.error(`${payloadKind} failed to send…\n${(err && err.stack) ? err.stack : err}`, err)
if (failedPayload && err.isRetryable !== false) enqueue(payloadKind, failedPayload)

@@ -38,11 +38,11 @@ cb(err)

const { queues, queueConsumers } = initRedelivery(networkStatus, client._logger, send)
const { queues, queueConsumers } = initRedelivery(networkStatus, client.__logger, send)
return {
sendReport: (report, cb = () => {}) => {
const url = client.config.endpoints.notify
sendEvent: (event, cb = () => {}) => {
const url = client._config.endpoints.notify
let body, opts
try {
body = payload.report(report, client.config.filters)
body = payload.event(event, client._config.redactedKeys)
opts = {

@@ -52,3 +52,3 @@ method: 'POST',

'Content-Type': 'application/json',
'Bugsnag-Api-Key': report.apiKey || client.config.apiKey,
'Bugsnag-Api-Key': event.apiKey || client._config.apiKey,
'Bugsnag-Payload-Version': '4',

@@ -59,13 +59,13 @@ 'Bugsnag-Sent-At': isoDate()

}
if (!networkStatus.isConnected || report.attemptImmediateDelivery === false) {
enqueue('report', { url, opts })
if (!networkStatus.isConnected || event.attemptImmediateDelivery === false) {
enqueue('event', { url, opts })
return cb(null)
}
client._logger.info(`Sending report ${report.events[0].errorClass}: ${report.events[0].errorMessage}`)
client.__logger.info(`Sending event ${event.events[0].errors[0].errorClass}: ${event.events[0].errors[0].errorMessage}`)
send(url, opts, err => {
if (err) return onerror(err, { url, opts }, 'report', cb)
if (err) return onerror(err, { url, opts }, 'event', cb)
cb(null)
})
} catch (e) {
onerror(e, { url, opts }, 'report', cb)
onerror(e, { url, opts }, 'event', cb)
}

@@ -75,7 +75,7 @@ },

sendSession: (session, cb = () => {}) => {
const url = client.config.endpoints.sessions
const url = client._config.endpoints.sessions
let body, opts
try {
body = payload.session(session, client.config.filters)
body = payload.session(session, client._config.redactedKeys)
opts = {

@@ -85,3 +85,3 @@ method: 'POST',

'Content-Type': 'application/json',
'Bugsnag-Api-Key': client.config.apiKey,
'Bugsnag-Api-Key': client._config.apiKey,
'Bugsnag-Payload-Version': '1',

@@ -96,3 +96,3 @@ 'Bugsnag-Sent-At': isoDate()

}
client._logger.info(`Sending session`)
client.__logger.info('Sending session')
send(url, opts, err => {

@@ -112,4 +112,4 @@ if (err) return onerror(err, { url, opts }, 'session', cb)

const queues = {
'report': new UndeliveredPayloadQueue('report', onQueueError),
'session': new UndeliveredPayloadQueue('session', onQueueError)
event: new UndeliveredPayloadQueue('event', onQueueError),
session: new UndeliveredPayloadQueue('session', onQueueError)
}

@@ -119,14 +119,14 @@

const queueConsumers = {
'report': new RedeliveryLoop(send, queues.report, onLoopError),
'session': new RedeliveryLoop(send, queues.session, onLoopError)
event: new RedeliveryLoop(send, queues.event, onLoopError),
session: new RedeliveryLoop(send, queues.session, onLoopError)
}
Promise.all([ queues.report.init(), queues.session.init() ])
Promise.all([queues.event.init(), queues.session.init()])
.then(() => {
networkStatus.watch(isConnected => {
if (isConnected) {
queueConsumers.report.start()
queueConsumers.event.start()
queueConsumers.session.start()
} else {
queueConsumers.report.stop()
queueConsumers.event.stop()
queueConsumers.session.stop()

@@ -133,0 +133,0 @@ }

{
"name": "@bugsnag/delivery-expo",
"version": "6.4.1",
"version": "7.0.0-alpha.0",
"main": "delivery.js",

@@ -23,3 +23,3 @@ "description": "@bugsnag/js delivery mechanism to send reports from Expo, using the FileSystem API to cache and retry sending failed reports",

"dependencies": {
"@bugsnag/core": "^6.4.1",
"@bugsnag/core": "^7.0.0-alpha.0",
"expo-file-system": "^6.0.2"

@@ -33,3 +33,3 @@ },

},
"gitHead": "7d8e6945877d7604deb08e8949f431a7a46801c2"
"gitHead": "44e41f2d9cce4a3aed93dd77e0c851119c2fe776"
}
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc