Skip to content
This repository has been archived by the owner on Jun 26, 2023. It is now read-only.

Commit

Permalink
feat: update uint8arrays (#105)
Browse files Browse the repository at this point in the history
  • Loading branch information
vasco-santos committed Aug 18, 2021
1 parent 120f9fb commit 9297a9c
Show file tree
Hide file tree
Showing 22 changed files with 41 additions and 42 deletions.
8 changes: 4 additions & 4 deletions .github/workflows/main.yml
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2
- uses: actions/setup-node@v1
- uses: actions/setup-node@v2
with:
node-version: 16
- run: npm install
Expand All @@ -29,7 +29,7 @@ jobs:
fail-fast: true
steps:
- uses: actions/checkout@v2
- uses: actions/setup-node@v1
- uses: actions/setup-node@v2
with:
node-version: ${{ matrix.node }}
- run: npm install
Expand All @@ -40,7 +40,7 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2
- uses: actions/setup-node@v1
- uses: actions/setup-node@v2
with:
node-version: 16
- run: npm install
Expand All @@ -50,7 +50,7 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2
- uses: actions/setup-node@v1
- uses: actions/setup-node@v2
with:
node-version: 16
- run: npm install
Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
"dependencies": {
"abort-controller": "^3.0.0",
"abortable-iterator": "^3.0.0",
"aegir": "^33.2.2",
"aegir": "^35.0.1",
"chai": "^4.3.4",
"chai-checkmark": "^1.0.1",
"delay": "^5.0.0",
Expand All @@ -51,7 +51,7 @@
"peer-id": "^0.15.0",
"sinon": "^11.1.1",
"streaming-iterables": "^6.0.0",
"uint8arrays": "^2.1.3"
"uint8arrays": "^3.0.0"
},
"devDependencies": {
"it-handshake": "^2.0.0"
Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/src/crypto/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ const duplexPair = require('it-pair/duplex')
const { pipe } = require('it-pipe')
const PeerId = require('peer-id')
const { collect } = require('streaming-iterables')
const uint8arrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const peers = require('../utils/peers')
const { UnexpectedPeerError } = require('libp2p-interfaces/src/crypto/errors')
Expand Down Expand Up @@ -55,7 +55,7 @@ module.exports = (common) => {
pipe(inboundResult.conn, inboundResult.conn)

// Send some data and collect the result
const input = uint8arrayFromString('data to encrypt')
const input = uint8ArrayFromString('data to encrypt')
const result = await pipe(
[input],
outboundResult.conn,
Expand Down
2 changes: 1 addition & 1 deletion packages/compliance-tests/src/pubsub/api.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ const sinon = require('sinon')

const pDefer = require('p-defer')
const pWaitFor = require('p-wait-for')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const topic = 'foo'
const data = uint8ArrayFromString('bar')
Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/src/pubsub/connection-handlers.js
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ const { expect } = require('aegir/utils/chai')
const sinon = require('sinon')
const pDefer = require('p-defer')
const pWaitFor = require('p-wait-for')
const uint8ArrayToString = require('uint8arrays/to-string')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { toString: uint8ArrayToString } = require('uint8arrays/to-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const { expectSet } = require('./utils')

Expand Down
2 changes: 1 addition & 1 deletion packages/compliance-tests/src/pubsub/emit-self.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
const { expect } = require('aegir/utils/chai')
const sinon = require('sinon')

const uint8ArrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const topic = 'foo'
const data = uint8ArrayFromString('bar')
Expand Down
2 changes: 1 addition & 1 deletion packages/compliance-tests/src/pubsub/messages.js
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ const { expect } = require('aegir/utils/chai')
const sinon = require('sinon')

const PeerId = require('peer-id')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const { utils } = require('libp2p-interfaces/src/pubsub')
const PeerStreams = require('libp2p-interfaces/src/pubsub/peer-streams')
Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/src/pubsub/multiple-nodes.js
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@ const sinon = require('sinon')
const delay = require('delay')
const pDefer = require('p-defer')
const pWaitFor = require('p-wait-for')
const uint8ArrayFromString = require('uint8arrays/from-string')
const uint8ArrayToString = require('uint8arrays/to-string')
const { toString: uint8ArrayToString } = require('uint8arrays/to-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const { expectSet } = require('./utils')

Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/src/pubsub/two-nodes.js
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@ const sinon = require('sinon')

const pDefer = require('p-defer')
const pWaitFor = require('p-wait-for')
const uint8ArrayFromString = require('uint8arrays/from-string')
const uint8ArrayToString = require('uint8arrays/to-string')
const { toString: uint8ArrayToString } = require('uint8arrays/to-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const {
first,
Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/src/stream-muxer/close-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -8,14 +8,14 @@ const { pipe } = require('it-pipe')
const { consume } = require('streaming-iterables')
const { source: abortable } = require('abortable-iterator')
const AbortController = require('abort-controller').default
const uint8arrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

function pause (ms) {
return new Promise(resolve => setTimeout(resolve, ms))
}

function randomBuffer () {
return uint8arrayFromString(Math.random().toString())
return uint8ArrayFromString(Math.random().toString())
}

const infiniteRandom = {
Expand Down
4 changes: 2 additions & 2 deletions packages/compliance-tests/src/transport/listen-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ const sinon = require('sinon')

const pWaitFor = require('p-wait-for')
const { pipe } = require('it-pipe')
const uint8arrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')
const { isValidTick } = require('./utils')

module.exports = (common) => {
Expand Down Expand Up @@ -74,7 +74,7 @@ module.exports = (common) => {
// Wait for the data send and close to finish
await Promise.all([
pipe(
[uint8arrayFromString('Some data that is never handled')],
[uint8ArrayFromString('Some data that is never handled')],
socket1
),
// Closer the listener (will take a couple of seconds to time out)
Expand Down
9 changes: 6 additions & 3 deletions packages/interfaces/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,10 @@
}
},
"eslintConfig": {
"extends": "ipfs"
"extends": "ipfs",
"ignorePatterns": [
"**/*.d.ts"
]
},
"scripts": {
"lint": "aegir lint",
Expand Down Expand Up @@ -66,12 +69,12 @@
"multiformats": "^9.1.2",
"peer-id": "^0.15.0",
"protobufjs": "^6.10.2",
"uint8arrays": "^2.1.3"
"uint8arrays": "^3.0.0"
},
"devDependencies": {
"@types/bl": "^5.0.1",
"@types/debug": "^4.1.5",
"aegir": "^33.0.0",
"aegir": "^35.0.1",
"events": "^3.3.0",
"it-pair": "^1.0.0",
"p-wait-for": "^3.2.0",
Expand Down
4 changes: 0 additions & 4 deletions packages/interfaces/src/pubsub/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -495,7 +495,6 @@ class PubsubBaseProtocol extends EventEmitter {
* Whether to accept a message from a peer
* Override to create a graylist
*
* @override
* @param {string} id
* @returns {boolean}
*/
Expand Down Expand Up @@ -653,7 +652,6 @@ class PubsubBaseProtocol extends EventEmitter {
/**
* Publishes messages to all subscribed peers
*
* @override
* @param {string} topic
* @param {Uint8Array} message
* @returns {Promise<void>}
Expand Down Expand Up @@ -718,7 +716,6 @@ class PubsubBaseProtocol extends EventEmitter {
/**
* Unsubscribe from the given topic.
*
* @override
* @param {string} topic
* @returns {void}
*/
Expand All @@ -736,7 +733,6 @@ class PubsubBaseProtocol extends EventEmitter {
/**
* Get the list of topics which the peer is subscribed to.
*
* @override
* @returns {Array<string>}
*/
getTopics () {
Expand Down
4 changes: 2 additions & 2 deletions packages/interfaces/src/pubsub/message/sign.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

const PeerId = require('peer-id')
const { RPC } = require('./rpc')
const uint8ArrayConcat = require('uint8arrays/concat')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { concat: uint8ArrayConcat } = require('uint8arrays/concat')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')
const SignPrefix = uint8ArrayFromString('libp2p-pubsub:')
const { normalizeOutRpcMessage } = require('../utils')

Expand Down
4 changes: 2 additions & 2 deletions packages/interfaces/src/pubsub/utils.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

// @ts-ignore libp2p crypto has no types
const randomBytes = require('libp2p-crypto/src/random-bytes')
const uint8ArrayToString = require('uint8arrays/to-string')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { toString: uint8ArrayToString } = require('uint8arrays/to-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')
const PeerId = require('peer-id')
const { sha256 } = require('multiformats/hashes/sha2')

Expand Down
2 changes: 1 addition & 1 deletion packages/interfaces/src/record/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ describe('your record', () => {
```js
const multicodec = require('multicodec')
const Record = require('libp2p-interfaces/src/record')
const fromString = require('uint8arrays/from-string')
const { fromString } = require('uint8arrays/from-string')
// const Protobuf = require('./record.proto')

const ENVELOPE_DOMAIN_PEER_RECORD = 'libp2p-peer-record'
Expand Down
2 changes: 1 addition & 1 deletion packages/interfaces/test/pubsub/emit-self.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ const {
PubsubImplementation
} = require('./utils')

const uint8ArrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const protocol = '/pubsub/1.0.0'
const topic = 'foo'
Expand Down
4 changes: 2 additions & 2 deletions packages/interfaces/test/pubsub/message.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@

const { expect } = require('aegir/utils/chai')
const sinon = require('sinon')
const uint8arrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const PubsubBaseImpl = require('../../src/pubsub')
const { SignaturePolicy } = require('../../src/pubsub/signature-policy')
Expand Down Expand Up @@ -35,7 +35,7 @@ describe('pubsub base messages', () => {
it('_buildMessage normalizes and signs messages', async () => {
const message = {
receivedFrom: peerId.toB58String(),
data: uint8arrayFromString('hello'),
data: uint8ArrayFromString('hello'),
topicIDs: ['test-topic']
}

Expand Down
2 changes: 1 addition & 1 deletion packages/interfaces/test/pubsub/pubsub.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ const { expect } = require('aegir/utils/chai')
const sinon = require('sinon')
const pWaitFor = require('p-wait-for')

const uint8ArrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const PeerStreams = require('../../src/pubsub/peer-streams')
const {
Expand Down
4 changes: 2 additions & 2 deletions packages/interfaces/test/pubsub/sign.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@
'use strict'

const { expect } = require('aegir/utils/chai')
const uint8ArrayConcat = require('uint8arrays/concat')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { concat: uint8ArrayConcat } = require('uint8arrays/concat')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const { RPC } = require('../../src/pubsub/message/rpc')
const {
Expand Down
4 changes: 2 additions & 2 deletions packages/interfaces/test/pubsub/topic-validators.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@ const pWaitFor = require('p-wait-for')
const errCode = require('err-code')

const PeerId = require('peer-id')
const uint8ArrayEquals = require('uint8arrays/equals')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { equals: uint8ArrayEquals } = require('uint8arrays/equals')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

const PeerStreams = require('../../src/pubsub/peer-streams')
const { SignaturePolicy } = require('../../src/pubsub/signature-policy')
Expand Down
2 changes: 1 addition & 1 deletion packages/interfaces/test/pubsub/utils.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@

const { expect } = require('aegir/utils/chai')
const utils = require('../../src/pubsub/utils')
const uint8ArrayFromString = require('uint8arrays/from-string')
const { fromString: uint8ArrayFromString } = require('uint8arrays/from-string')

describe('utils', () => {
it('randomSeqno', () => {
Expand Down

0 comments on commit 9297a9c

Please sign in to comment.