Compare commits
5 Commits
19e03cf360
...
19288853e5
Author | SHA1 | Date | |
---|---|---|---|
19288853e5 | |||
79e338958a | |||
69a2cf4eac | |||
102ab08f74 | |||
421527242e |
@ -39,7 +39,7 @@ pnpm run build
|
|||||||
```
|
```
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
pm2 start --name "Sigit-DVM" -- start
|
pm2 start --name "Sigit-DVM" npm -- start
|
||||||
```
|
```
|
||||||
|
|
||||||
## Make PM2 auto start on reboot
|
## Make PM2 auto start on reboot
|
||||||
|
@ -18,7 +18,8 @@ export async function blockChainBlockNumberJob(
|
|||||||
return closestObject.block_index.toString()
|
return closestObject.block_index.toString()
|
||||||
})
|
})
|
||||||
.catch((err) => {
|
.catch((err) => {
|
||||||
console.log('err in blockChain request :>> ', err)
|
log('err in blockChain request :>> ', err)
|
||||||
|
|
||||||
return Promise.reject(err)
|
return Promise.reject(err)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@ -1,9 +1,8 @@
|
|||||||
import { NDKEvent, type NostrEvent } from '@nostr-dev-kit/ndk'
|
import { NDKEvent, type NostrEvent } from '@nostr-dev-kit/ndk'
|
||||||
import axios from 'axios'
|
import axios from 'axios'
|
||||||
import FormData from 'form-data'
|
import FormData from 'form-data'
|
||||||
import { log } from '../main.js'
|
|
||||||
import { fetchFileFromInput } from '../utils/fetch-file-from-input.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 { fileTypeFromFile, type FileTypeResult } from 'file-type';
|
||||||
import { exec } from 'child_process'
|
import { exec } from 'child_process'
|
||||||
import fs from 'fs'
|
import fs from 'fs'
|
||||||
@ -43,7 +42,8 @@ export async function speechToTextJob(event: NDKEvent): Promise<string> {
|
|||||||
}
|
}
|
||||||
const formData = new FormData()
|
const formData = new FormData()
|
||||||
const a = fs.createReadStream(file)
|
const a = fs.createReadStream(file)
|
||||||
console.log({ a })
|
|
||||||
|
log({ a })
|
||||||
|
|
||||||
formData.append('file', a)
|
formData.append('file', a)
|
||||||
formData.append('model', 'whisper-1')
|
formData.append('model', 'whisper-1')
|
||||||
@ -57,12 +57,14 @@ export async function speechToTextJob(event: NDKEvent): Promise<string> {
|
|||||||
})
|
})
|
||||||
.then((response) => {
|
.then((response) => {
|
||||||
const { text } = response.data
|
const { text } = response.data
|
||||||
console.log({ text })
|
|
||||||
|
log({ text })
|
||||||
|
|
||||||
resolve(text)
|
resolve(text)
|
||||||
// Handle response
|
// Handle response
|
||||||
})
|
})
|
||||||
.catch((error) => {
|
.catch((error) => {
|
||||||
console.log({ error })
|
log({ error })
|
||||||
// Handle error
|
// Handle error
|
||||||
})
|
})
|
||||||
}, 1000)
|
}, 1000)
|
||||||
@ -78,9 +80,11 @@ export async function speechToTextJob(event: NDKEvent): Promise<string> {
|
|||||||
const endTime = range[3]
|
const endTime = range[3]
|
||||||
const randomName = Math.random().toString(36).substring(7) + '.mp3'
|
const randomName = Math.random().toString(36).substring(7) + '.mp3'
|
||||||
const command = `ffmpeg -ss ${startTime} -to ${endTime} -i ${file} -vn -acodec copy ${randomName}`
|
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) => {
|
exec(command, (error, stderr, stdout) => {
|
||||||
console.log('ffmpeg', { error, stderr, stdout })
|
log('ffmpeg', { error, stderr, stdout })
|
||||||
|
|
||||||
whisperCommand(resolve, randomName)
|
whisperCommand(resolve, randomName)
|
||||||
})
|
})
|
||||||
|
@ -4,7 +4,7 @@ import { inProgress } from '../jobs/reactions/in-progress.js'
|
|||||||
import { log } from '../main.js'
|
import { log } from '../main.js'
|
||||||
|
|
||||||
export async function onNewSummarizationJob(event: NDKEvent): Promise<void> {
|
export async function onNewSummarizationJob(event: NDKEvent): Promise<void> {
|
||||||
console.log('New summarization job')
|
log('New summarization job')
|
||||||
|
|
||||||
await validateJobRequest(event).catch((err) =>
|
await validateJobRequest(event).catch((err) =>
|
||||||
log(`Job validation error: `, err)
|
log(`Job validation error: `, err)
|
||||||
|
@ -14,7 +14,7 @@ export async function publishStatus(
|
|||||||
tags: [['status', status], ...extraTags]
|
tags: [['status', status], ...extraTags]
|
||||||
})
|
})
|
||||||
|
|
||||||
console.log({ extraTags })
|
log({ extraTags })
|
||||||
|
|
||||||
reactEvent.tag(event, 'job')
|
reactEvent.tag(event, 'job')
|
||||||
await reactEvent.sign()
|
await reactEvent.sign()
|
||||||
|
@ -257,9 +257,7 @@ async function processJobEvent(event: NDKEvent, type: JobType): Promise<void> {
|
|||||||
|
|
||||||
await startProcessing()
|
await startProcessing()
|
||||||
|
|
||||||
await publishStatus(event, 'finished').catch((err) =>
|
await publishStatus(event, 'finished').catch((err) => log('err :>> ', err))
|
||||||
console.log('err :>> ', err)
|
|
||||||
)
|
|
||||||
|
|
||||||
if (jobAmount > paidAmount && waitForPaymentBeforePublishingResult()) {
|
if (jobAmount > paidAmount && waitForPaymentBeforePublishingResult()) {
|
||||||
await reqPayment()
|
await reqPayment()
|
||||||
|
@ -2,7 +2,7 @@ import { NDKEvent, type NostrEvent } from '@nostr-dev-kit/ndk'
|
|||||||
import validateExpiration from './expiration.js'
|
import validateExpiration from './expiration.js'
|
||||||
import validateRequester from './requester.js'
|
import validateRequester from './requester.js'
|
||||||
import validateNoRecentResults from './no-recent-results.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'
|
import { addAmount } from '../job-types/speech-to-text.js'
|
||||||
|
|
||||||
export async function validateJobRequest(event: NDKEvent): Promise<void> {
|
export async function validateJobRequest(event: NDKEvent): Promise<void> {
|
||||||
@ -40,7 +40,8 @@ export async function requirePayment(
|
|||||||
payReq.tag(event, 'job')
|
payReq.tag(event, 'job')
|
||||||
|
|
||||||
await payReq.sign()
|
await payReq.sign()
|
||||||
console.log(payReq.rawEvent())
|
|
||||||
|
log(payReq.rawEvent())
|
||||||
|
|
||||||
if (publish !== false) await payReq.publish()
|
if (publish !== false) await payReq.publish()
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user