mirror of
https://github.com/block-core/angor-hub-old.git
synced 2026-02-23 12:12:23 +01:00
Rename MetadataQueueService to MetadataService, update imports and references, and delete MetadataQueueService file.
This commit is contained in:
@@ -5,7 +5,7 @@ import { Chat, Contact, Profile } from 'app/components/chat/chat.types';
|
||||
import { StorageService } from 'app/services/storage.service';
|
||||
import { RelayService } from 'app/services/relay.service';
|
||||
import { SignerService } from 'app/services/signer.service';
|
||||
import { MetadataQueueService } from 'app/services/metadata-queue.service';
|
||||
import { MetadataService } from 'app/services/metadata.service';
|
||||
import { Filter, getEventHash, NostrEvent } from 'nostr-tools';
|
||||
import { EncryptedDirectMessage } from 'nostr-tools/kinds';
|
||||
|
||||
@@ -29,7 +29,7 @@ export class ChatService implements OnDestroy {
|
||||
private _signerService: SignerService,
|
||||
private _storageService: StorageService,
|
||||
private _relayService: RelayService,
|
||||
private _metadataQueueService: MetadataQueueService
|
||||
private _metadataQueueService: MetadataService
|
||||
) {
|
||||
|
||||
this._metadataQueueService.processingStatus$.subscribe((status) => {
|
||||
|
||||
@@ -5,7 +5,7 @@ import { Subscription, BehaviorSubject, Subject, from } from 'rxjs';
|
||||
import { concatMap, delay, takeUntil } from 'rxjs/operators';
|
||||
import { StorageService } from 'app/services/storage.service';
|
||||
import { SubscriptionService } from 'app/services/subscription.service';
|
||||
import { MetadataQueueService } from 'app/services/metadata-queue.service';
|
||||
import { MetadataService } from 'app/services/metadata.service';
|
||||
import { AngorCardComponent } from '@angor/components/card';
|
||||
import { TextFieldModule } from '@angular/cdk/text-field';
|
||||
import { MatButtonModule } from '@angular/material/button';
|
||||
@@ -93,7 +93,7 @@ export class PostEventComponent implements OnInit, OnDestroy {
|
||||
private _router: Router,
|
||||
private _storageService: StorageService,
|
||||
private subscriptionService: SubscriptionService,
|
||||
private metadataQueueService: MetadataQueueService,
|
||||
private metadataQueueService: MetadataService,
|
||||
private _changeDetectorRef: ChangeDetectorRef,
|
||||
public parseContent: ParseContentService
|
||||
) {}
|
||||
|
||||
@@ -25,7 +25,7 @@ interface ProcessingStatus {
|
||||
@Injectable({
|
||||
providedIn: 'root',
|
||||
})
|
||||
export class MetadataQueueService implements OnDestroy {
|
||||
export class MetadataService implements OnDestroy {
|
||||
private readonly BATCH_SIZE = 50;
|
||||
private readonly PROCESS_INTERVAL = 2000; // 2 seconds
|
||||
private readonly MAX_RETRY_ATTEMPTS = 3;
|
||||
Reference in New Issue
Block a user