mirror of
https://github.com/Permissionless-Software-Foundation/bch-dex.git
synced 2026-09-22 01:02:00 -07:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0811024030 | ||
|
|
737d35463d | ||
|
|
6dddfbdcb6 | ||
|
|
fc2d7b4b9b |
@@ -4,8 +4,11 @@ const CounterOffer = new mongoose.Schema({
|
||||
nostrEventId: { type: String, required: true }, // Nostr Event Id.
|
||||
takerAddr: { type: String, default: null },
|
||||
takerNpub: { type: String, default: null },
|
||||
makerNpub: { type: String, default: null },
|
||||
counterOfferAddr: { type: String, default: null },
|
||||
counterOfferUtxo: { type: String, default: null }
|
||||
counterOfferUtxo: { type: String, default: null },
|
||||
takerOfferUtxo: { type: String, default: null },
|
||||
tokenId: { type: String, default: null }
|
||||
})
|
||||
|
||||
export default mongoose.model('counterOffer', CounterOffer)
|
||||
|
||||
@@ -46,6 +46,7 @@ const Offer = new mongoose.Schema({
|
||||
immutableDataCid: { type: String, default: null },
|
||||
mutableDataCid: { type: String, default: null },
|
||||
tokenIconUrl: { type: String, default: null },
|
||||
tokenData: { type: Object },
|
||||
tokenCategories: { type: Array, default: [] },
|
||||
tokenTags: { type: Array, default: [] },
|
||||
userDataStr: { type: String }, // Token user data
|
||||
|
||||
@@ -16,8 +16,11 @@ class CounterOfferEntity {
|
||||
nostrEventId,
|
||||
takerAddr,
|
||||
takerNpub,
|
||||
makerNpub,
|
||||
counterOfferAddr,
|
||||
counterOfferUtxo
|
||||
counterOfferUtxo,
|
||||
takerOfferUtxo,
|
||||
tokenId
|
||||
} = offerData.data
|
||||
|
||||
// Input Validation
|
||||
@@ -37,13 +40,25 @@ class CounterOfferEntity {
|
||||
if (counterOfferUtxo && typeof counterOfferUtxo !== 'string') {
|
||||
throw new Error("Property 'counterOfferUtxo' must be a string.")
|
||||
}
|
||||
if (takerOfferUtxo && typeof takerOfferUtxo !== 'string') {
|
||||
throw new Error("Property 'takerOfferUtxo' must be a string.")
|
||||
}
|
||||
if (tokenId && typeof tokenId !== 'string') {
|
||||
throw new Error("Property 'tokenId' must be a string.")
|
||||
}
|
||||
if (makerNpub && typeof makerNpub !== 'string') {
|
||||
throw new Error("Property 'makerNpub' must be a string.")
|
||||
}
|
||||
|
||||
const validatedCounterOfferData = {
|
||||
nostrEventId,
|
||||
takerAddr,
|
||||
takerNpub,
|
||||
counterOfferAddr,
|
||||
counterOfferUtxo
|
||||
counterOfferUtxo,
|
||||
takerOfferUtxo,
|
||||
tokenId,
|
||||
makerNpub
|
||||
}
|
||||
|
||||
return validatedCounterOfferData
|
||||
|
||||
@@ -148,6 +148,7 @@ class OfferUseCases {
|
||||
const immutableDataCid = tokenData.immutableData
|
||||
offerEntity.mutableDataCid = mutableDataCid
|
||||
offerEntity.immutableDataCid = immutableDataCid
|
||||
offerEntity.tokenData = tokenData
|
||||
|
||||
// Get the mutable data from the cid if it exists.
|
||||
if (mutableDataCid && typeof mutableDataCid === 'string') {
|
||||
@@ -608,6 +609,8 @@ class OfferUseCases {
|
||||
// Create counter offer entity for nostr event id if it not exist
|
||||
const existingCounterOffer = await this.CounterOfferModel.findOne(({ nostrEventId: eventId }))
|
||||
if (!existingCounterOffer) {
|
||||
// Add taker offer utxo to counter offer data.
|
||||
offerData.data.takerOfferUtxo = offerData.data.utxoTxid
|
||||
const counterOEntity = this.counterOfferEntity.validate(offerData)
|
||||
// Create new counter offfer model and save it.
|
||||
const counterOffer = new this.CounterOfferModel(counterOEntity)
|
||||
@@ -998,6 +1001,7 @@ class OfferUseCases {
|
||||
const immutableDataCid = tokenData.immutableData
|
||||
offer.mutableDataCid = mutableDataCid
|
||||
offer.immutableDataCid = immutableDataCid
|
||||
offer.tokenData = tokenData
|
||||
|
||||
// Get the mutable data from the cid if it exists.
|
||||
if (mutableDataCid && typeof mutableDataCid === 'string') {
|
||||
|
||||
@@ -11,7 +11,7 @@ let sandbox
|
||||
let uut
|
||||
|
||||
describe('#CounterOffer-Entity', () => {
|
||||
before(async () => {})
|
||||
before(async () => { })
|
||||
|
||||
beforeEach(() => {
|
||||
uut = new CounterOfferEntity()
|
||||
@@ -24,7 +24,7 @@ describe('#CounterOffer-Entity', () => {
|
||||
describe('#validate', () => {
|
||||
it('should throw an error if data is not provided', () => {
|
||||
try {
|
||||
uut.validate({ })
|
||||
uut.validate({})
|
||||
} catch (err) {
|
||||
assert.include(err.message, 'Input to counterOffer.validate() must be an object with a data property.')
|
||||
}
|
||||
@@ -59,12 +59,26 @@ describe('#CounterOffer-Entity', () => {
|
||||
assert.include(err.message, "Property 'takerNpub' must be a string")
|
||||
}
|
||||
})
|
||||
it('should throw an error if provided makerNpub is not string', () => {
|
||||
try {
|
||||
const inObj = {
|
||||
nostrEventId: 'nostr event id',
|
||||
takerAddr: 'taker address',
|
||||
takerNpub: 'npub',
|
||||
makerNpub: 1234
|
||||
}
|
||||
uut.validate({ data: inObj })
|
||||
} catch (err) {
|
||||
assert.include(err.message, "Property 'makerNpub' must be a string")
|
||||
}
|
||||
})
|
||||
it('should throw an error if provided counterOfferAddr is not string', () => {
|
||||
try {
|
||||
const inObj = {
|
||||
nostrEventId: 'nostr event id',
|
||||
takerAddr: 'taker address',
|
||||
takerNpub: 'npub',
|
||||
makerNpub: 'npub',
|
||||
counterOfferAddr: 1234
|
||||
}
|
||||
uut.validate({ data: inObj })
|
||||
@@ -78,6 +92,7 @@ describe('#CounterOffer-Entity', () => {
|
||||
nostrEventId: 'nostr event id',
|
||||
takerAddr: 'taker address',
|
||||
takerNpub: 'npub',
|
||||
makerNpub: 'npub',
|
||||
counterOfferAddr: 'counter offer address',
|
||||
counterOfferUtxo: 1234
|
||||
}
|
||||
@@ -86,13 +101,50 @@ describe('#CounterOffer-Entity', () => {
|
||||
assert.include(err.message, "Property 'counterOfferUtxo' must be a string")
|
||||
}
|
||||
})
|
||||
it('should throw an error if provided takerOfferUtxo is not string', () => {
|
||||
try {
|
||||
const inObj = {
|
||||
nostrEventId: 'nostr event id',
|
||||
takerAddr: 'taker address',
|
||||
takerNpub: 'npub',
|
||||
makerNpub: 'npub',
|
||||
counterOfferAddr: 'counter offer address',
|
||||
counterOfferUtxo: 'utxo txid',
|
||||
takerOfferUtxo: 1234
|
||||
}
|
||||
uut.validate({ data: inObj })
|
||||
} catch (err) {
|
||||
assert.include(err.message, "Property 'takerOfferUtxo' must be a string")
|
||||
}
|
||||
})
|
||||
it('should throw an error if provided tokenId is not string', () => {
|
||||
try {
|
||||
const inObj = {
|
||||
nostrEventId: 'nostr event id',
|
||||
takerAddr: 'taker address',
|
||||
takerNpub: 'npub',
|
||||
makerNpub: 'npub',
|
||||
counterOfferAddr: 'counter offer address',
|
||||
counterOfferUtxo: 'utxo txid',
|
||||
takerOfferUtxo: 'utxo txid',
|
||||
tokenId: 1234
|
||||
}
|
||||
uut.validate({ data: inObj })
|
||||
} catch (err) {
|
||||
assert.include(err.message, "Property 'tokenId' must be a string")
|
||||
}
|
||||
})
|
||||
|
||||
it('should return a counter offer object', () => {
|
||||
const inObj = {
|
||||
nostrEventId: 'nostr event id',
|
||||
takerAddr: 'taker address',
|
||||
takerNpub: 'npub',
|
||||
makerNpub: 'npub',
|
||||
counterOfferAddr: 'counter offer address',
|
||||
counterOfferUtxo: 'utxo txid'
|
||||
counterOfferUtxo: 'utxo txid',
|
||||
takerOfferUtxo: 'utxo txid',
|
||||
tokenId: 'token id'
|
||||
}
|
||||
|
||||
const counterOfferEntity = uut.validate({ data: inObj })
|
||||
@@ -106,11 +158,20 @@ describe('#CounterOffer-Entity', () => {
|
||||
assert.property(counterOfferEntity, 'takerNpub')
|
||||
assert.equal(counterOfferEntity.takerNpub, inObj.takerNpub)
|
||||
|
||||
assert.property(counterOfferEntity, 'makerNpub')
|
||||
assert.equal(counterOfferEntity.makerNpub, inObj.makerNpub)
|
||||
|
||||
assert.property(counterOfferEntity, 'counterOfferAddr')
|
||||
assert.equal(counterOfferEntity.counterOfferAddr, inObj.counterOfferAddr)
|
||||
|
||||
assert.property(counterOfferEntity, 'counterOfferUtxo')
|
||||
assert.equal(counterOfferEntity.counterOfferUtxo, inObj.counterOfferUtxo)
|
||||
|
||||
assert.property(counterOfferEntity, 'takerOfferUtxo')
|
||||
assert.equal(counterOfferEntity.takerOfferUtxo, inObj.takerOfferUtxo)
|
||||
|
||||
assert.property(counterOfferEntity, 'tokenId')
|
||||
assert.equal(counterOfferEntity.tokenId, inObj.tokenId)
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
@@ -107,14 +107,14 @@ describe('#offer-use-case', () => {
|
||||
const result = await uut.createOffer(offerObj)
|
||||
assert.isFalse(result)
|
||||
})
|
||||
|
||||
it('should create offer with mutable data', async () => {
|
||||
it('should create offer with token data', async () => {
|
||||
const tokenDataMock = mockData.nftTokenData01
|
||||
const offerObj = mockData.offerMockData
|
||||
const mutableDataMock = mockData.mutableDataMock
|
||||
const offerEntityMock = Object.assign({}, mockData.offerMockData.data)
|
||||
|
||||
// Mock dependencies
|
||||
// sandbox.stub(uut.adapters.wallet.bchWallet, 'utxoIsValid').resolves(false)
|
||||
sandbox.stub(uut.offerEntity, 'validate').returns(offerEntityMock)
|
||||
sandbox.stub(uut, 'findOfferByTxid').throws(new Error('offer not found'))
|
||||
sandbox.stub(uut.retryQueue, 'addToQueue')
|
||||
.onCall(0).resolves({}) // Utxo Status call
|
||||
@@ -123,6 +123,31 @@ describe('#offer-use-case', () => {
|
||||
|
||||
const result = await uut.createOffer(offerObj)
|
||||
assert.isTrue(result)
|
||||
console.log('offerEntityMock', offerEntityMock)
|
||||
assert.property(offerEntityMock, 'tokenData')
|
||||
})
|
||||
it('should create offer with mutable data', async () => {
|
||||
const tokenDataMock = mockData.nftTokenData01
|
||||
const offerObj = mockData.offerMockData
|
||||
const mutableDataMock = mockData.mutableDataMock
|
||||
const offerEntityMock = Object.assign({}, mockData.offerMockData.data)
|
||||
|
||||
// Mock dependencies
|
||||
sandbox.stub(uut.offerEntity, 'validate').returns(offerEntityMock)
|
||||
sandbox.stub(uut, 'findOfferByTxid').throws(new Error('offer not found'))
|
||||
sandbox.stub(uut.retryQueue, 'addToQueue')
|
||||
.onCall(0).resolves({}) // Utxo Status call
|
||||
.onCall(1).resolves(tokenDataMock) // Token Data call
|
||||
.onCall(2).resolves(mutableDataMock)
|
||||
|
||||
const result = await uut.createOffer(offerObj)
|
||||
assert.isTrue(result)
|
||||
console.log('offerEntityMock', offerEntityMock)
|
||||
|
||||
assert.property(offerEntityMock, 'tokenIconUrl')
|
||||
assert.property(offerEntityMock, 'tokenCategories')
|
||||
assert.property(offerEntityMock, 'tokenTags')
|
||||
assert.property(offerEntityMock, 'lastUpdatedTokenData')
|
||||
})
|
||||
|
||||
it('should skip userData stringify error', async () => {
|
||||
@@ -1106,6 +1131,12 @@ describe('#offer-use-case', () => {
|
||||
const offer = await uut.syncOfferMutableData('tokenId')
|
||||
assert.isObject(offer)
|
||||
assert.isNumber(offer.lastUpdatedTokenData)
|
||||
|
||||
assert.property(offer, 'tokenData')
|
||||
assert.property(offer, 'tokenIconUrl')
|
||||
assert.property(offer, 'tokenCategories')
|
||||
assert.property(offer, 'tokenTags')
|
||||
assert.property(offer, 'lastUpdatedTokenData')
|
||||
})
|
||||
|
||||
it('should skip userData stringify error', async () => {
|
||||
|
||||
Reference in New Issue
Block a user