Merge pull request 'error-handling' (#7) from error-handling into master

Reviewed-on: #7
Reviewed-by: s <sabir@4gl.io>
This commit is contained in:
Otto 2024-07-02 07:56:12 +00:00
commit 8d335b275e
7 changed files with 23 additions and 19 deletions

View File

@ -6,11 +6,11 @@ Building on the great work of Pablo: https://github.com/pablof7z/nostr-data-vend
The following Jobs are supported by this DVM:
- Get OnNostrSince Block Height
- Get OnNostrSince Block Height
- Send nPub get Block Height (from blockchain.info)
- Send nPub get Block Height (from blockchain.info)
- More job types will be added in the future
- More job types will be added in the future
# Demo video
@ -39,7 +39,7 @@ pnpm run build
```
```sh
pm2 start --name "Sigit-DVM" -- start
pm2 start --name "Sigit-DVM" npm -- start
```
## Make PM2 auto start on reboot

View File

@ -18,7 +18,8 @@ export async function blockChainBlockNumberJob(
return closestObject.block_index.toString()
})
.catch((err) => {
console.log('err in blockChain request :>> ', err)
log('err in blockChain request :>> ', err)
return Promise.reject(err)
})

View File

@ -1,9 +1,8 @@
import { NDKEvent, type NostrEvent } from '@nostr-dev-kit/ndk'
import axios from 'axios'
import FormData from 'form-data'
import { log } from '../main.js'
import { fetchFileFromInput } from '../utils/fetch-file-from-input.js'
import { ndk } from '../main.js'
import { ndk, log } from '../main.js'
// import { fileTypeFromFile, type FileTypeResult } from 'file-type';
import { exec } from 'child_process'
import fs from 'fs'
@ -43,7 +42,8 @@ export async function speechToTextJob(event: NDKEvent): Promise<string> {
}
const formData = new FormData()
const a = fs.createReadStream(file)
console.log({ a })
log({ a })
formData.append('file', a)
formData.append('model', 'whisper-1')
@ -57,12 +57,14 @@ export async function speechToTextJob(event: NDKEvent): Promise<string> {
})
.then((response) => {
const { text } = response.data
console.log({ text })
log({ text })
resolve(text)
// Handle response
})
.catch((error) => {
console.log({ error })
log({ error })
// Handle error
})
}, 1000)
@ -78,9 +80,11 @@ export async function speechToTextJob(event: NDKEvent): Promise<string> {
const endTime = range[3]
const randomName = Math.random().toString(36).substring(7) + '.mp3'
const command = `ffmpeg -ss ${startTime} -to ${endTime} -i ${file} -vn -acodec copy ${randomName}`
console.log({ startTime, endTime, randomName, command })
log({ startTime, endTime, randomName, command })
exec(command, (error, stderr, stdout) => {
console.log('ffmpeg', { error, stderr, stdout })
log('ffmpeg', { error, stderr, stdout })
whisperCommand(resolve, randomName)
})

View File

@ -4,7 +4,7 @@ import { inProgress } from '../jobs/reactions/in-progress.js'
import { log } from '../main.js'
export async function onNewSummarizationJob(event: NDKEvent): Promise<void> {
console.log('New summarization job')
log('New summarization job')
await validateJobRequest(event).catch((err) =>
log(`Job validation error: `, err)

View File

@ -14,7 +14,7 @@ export async function publishStatus(
tags: [['status', status], ...extraTags]
})
console.log({ extraTags })
log({ extraTags })
reactEvent.tag(event, 'job')
await reactEvent.sign()

View File

@ -257,9 +257,7 @@ async function processJobEvent(event: NDKEvent, type: JobType): Promise<void> {
await startProcessing()
await publishStatus(event, 'finished').catch((err) =>
console.log('err :>> ', err)
)
await publishStatus(event, 'finished').catch((err) => log('err :>> ', err))
if (jobAmount > paidAmount && waitForPaymentBeforePublishingResult()) {
await reqPayment()

View File

@ -2,7 +2,7 @@ import { NDKEvent, type NostrEvent } from '@nostr-dev-kit/ndk'
import validateExpiration from './expiration.js'
import validateRequester from './requester.js'
import validateNoRecentResults from './no-recent-results.js'
import { ndk } from '../main.js'
import { ndk, log } from '../main.js'
import { addAmount } from '../job-types/speech-to-text.js'
export async function validateJobRequest(event: NDKEvent): Promise<void> {
@ -40,7 +40,8 @@ export async function requirePayment(
payReq.tag(event, 'job')
await payReq.sign()
console.log(payReq.rawEvent())
log(payReq.rawEvent())
if (publish !== false) await payReq.publish()