zoriya/Aeris
1
0
Fork 0
mirror of https://github.com/zoriya/Aeris.git synced 2026-06-02 10:57:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Removing twitter actions

Browse Source
This commit is contained in:
Zoe Roux
2022-03-06 00:42:10 +01:00
parent c35d82646d
commit aae3375a4f
1 changed files with 3 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker/src/services/twitter.ts
+3 -26
View File
@@ -1,7 +1,6 @@
import { exhaustMap, from, fromEventPattern, map, Observable } from "rxjs";
import { Pipeline, PipelineEnv, PipelineType, ReactionType, ServiceType } from "../models/pipeline";
import { ETwitterStreamEvent, TweetStream, TwitterApi } from "twitter-api-v2";
import { action, BaseService, reaction, service } from "../models/base-service";
import { Pipeline, PipelineEnv, ReactionType, ServiceType } from "../models/pipeline";
import { TwitterApi } from "twitter-api-v2";
import { BaseService, reaction, service } from "../models/base-service";
@service(ServiceType.Twitter)
export class Twitter extends BaseService {
@@ -36,28 +35,6 @@ export class Twitter extends BaseService {
});
}
// private async _createStream(): Promise<TweetStream> {
// const stream = await this._.v2.sampleStream();
// stream.on(ETwitterStreamEvent.Connected, () => console.log('Stream is started.'));
// stream.on(ETwitterStreamEvent.ConnectionError, err => console.log('Connection error!', err));
// stream.on(ETwitterStreamEvent.ConnectionClosed, () => console.log('Connection has been closed.'));
// return stream;
// }
// @action(PipelineType.OnTweet, [])
// listenTweet(params: any): Observable<PipelineEnv> {
// return from(Twitter._createStream())
// .pipe(
// exhaustMap((stream: TweetStream) =>
// fromEventPattern(
// handler => stream.on(ETwitterStreamEvent.Data, handler),
// () => stream.close()
// )
// )
// );
// }
@reaction(ReactionType.FollowUser, ['user_name'])
async followUser(params: any): Promise<PipelineEnv> {
await this._refreshIfNeeded();