feat: Implement update credentials endpoint
This commit is contained in:
@@ -4,15 +4,19 @@ import Field from '../../types/field';
|
|||||||
|
|
||||||
export default class Twitter {
|
export default class Twitter {
|
||||||
client: any
|
client: any
|
||||||
|
credentialsData: any
|
||||||
appData: any
|
appData: any
|
||||||
|
|
||||||
constructor(credentialsData: any) {
|
constructor(credentialsData: any) {
|
||||||
this.client = new TwitterApi({
|
this.client = new TwitterApi({
|
||||||
appKey: credentialsData.consumerKey,
|
appKey: credentialsData.consumerKey,
|
||||||
appSecret: credentialsData.consumerSecret
|
appSecret: credentialsData.consumerSecret,
|
||||||
|
accessToken: credentialsData.accessToken,
|
||||||
|
accessSecret: credentialsData.accessSecret
|
||||||
});
|
});
|
||||||
|
|
||||||
this.appData = App.findOneByName('twitter')
|
this.credentialsData = credentialsData;
|
||||||
|
this.appData = App.findOneByName('twitter');
|
||||||
}
|
}
|
||||||
|
|
||||||
async createAuthLink() {
|
async createAuthLink() {
|
||||||
@@ -21,4 +25,17 @@ export default class Twitter {
|
|||||||
|
|
||||||
return this.client.generateAuthLink(callbackUrl);
|
return this.client.generateAuthLink(callbackUrl);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async verifyCredentials() {
|
||||||
|
const verifiedCredentials = await this.client.login(this.credentialsData.oauthVerifier)
|
||||||
|
|
||||||
|
return {
|
||||||
|
consumerKey: this.credentialsData.consumerKey,
|
||||||
|
consumerSecret: this.credentialsData.consumerSecret,
|
||||||
|
accessToken: verifiedCredentials.accessToken,
|
||||||
|
accessSecret: verifiedCredentials.accessSecret,
|
||||||
|
userId: verifiedCredentials.userId,
|
||||||
|
screenName: verifiedCredentials.screenName
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
@@ -90,6 +90,27 @@
|
|||||||
"value": "{createAuthLink.url}"
|
"value": "{createAuthLink.url}"
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"step": 4,
|
||||||
|
"type": "mutation",
|
||||||
|
"name": "updateCredential",
|
||||||
|
"fields": [
|
||||||
|
{
|
||||||
|
"name": "id",
|
||||||
|
"value": "{createCredential.id}"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "data",
|
||||||
|
"value": null,
|
||||||
|
"fields": [
|
||||||
|
{
|
||||||
|
"name": "oauthVerifier",
|
||||||
|
"value": "{openTwitterAuthPopup.oauth_verifier}"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
@@ -17,6 +17,16 @@ const createAuthLinkResolver = async (params: Params, req: RequestWithCurrentUse
|
|||||||
const appInstance = new appClass(credential.data)
|
const appInstance = new appClass(credential.data)
|
||||||
const authLink = await appInstance.createAuthLink();
|
const authLink = await appInstance.createAuthLink();
|
||||||
|
|
||||||
|
await credential.$query().patch({
|
||||||
|
data: {
|
||||||
|
...credential.data,
|
||||||
|
url: authLink.url,
|
||||||
|
accessToken: authLink.oauth_token,
|
||||||
|
accessSecret: authLink.oauth_token_secret,
|
||||||
|
},
|
||||||
|
verified: authLink.oauth_callback_confirmed === 'true' ? true : false
|
||||||
|
})
|
||||||
|
|
||||||
return authLink;
|
return authLink;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
45
packages/backend/src/graphql/mutations/update-credential.ts
Normal file
45
packages/backend/src/graphql/mutations/update-credential.ts
Normal file
@@ -0,0 +1,45 @@
|
|||||||
|
import { GraphQLString, GraphQLNonNull } from 'graphql';
|
||||||
|
import Credential from '../../models/credential';
|
||||||
|
import credentialType from '../types/credential';
|
||||||
|
import twitterCredentialInputType from '../types/twitter-credential-input';
|
||||||
|
import RequestWithCurrentUser from '../../types/express/request-with-current-user';
|
||||||
|
|
||||||
|
type Params = {
|
||||||
|
id: string,
|
||||||
|
data: object
|
||||||
|
}
|
||||||
|
const updateCredentialResolver = async (params: Params, req: RequestWithCurrentUser) => {
|
||||||
|
let credential = await Credential.query().findOne({
|
||||||
|
user_id: req.currentUser.id,
|
||||||
|
id: params.id
|
||||||
|
})
|
||||||
|
|
||||||
|
credential = await credential.$query().patchAndFetch({
|
||||||
|
data: {
|
||||||
|
...credential.data,
|
||||||
|
...params.data
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
const appClass = (await import(`../../apps/${credential.key}`)).default;
|
||||||
|
|
||||||
|
const appInstance = new appClass(credential.data)
|
||||||
|
const verifiedCredentials = await appInstance.verifyCredentials();
|
||||||
|
|
||||||
|
credential = await credential.$query().patchAndFetch({
|
||||||
|
data: verifiedCredentials
|
||||||
|
})
|
||||||
|
|
||||||
|
return credential;
|
||||||
|
}
|
||||||
|
|
||||||
|
const updateCredential = {
|
||||||
|
type: credentialType,
|
||||||
|
args: {
|
||||||
|
id: { type: GraphQLNonNull(GraphQLString) },
|
||||||
|
data: { type: GraphQLNonNull(twitterCredentialInputType) }
|
||||||
|
},
|
||||||
|
resolve: (_: any, params: Params, req: RequestWithCurrentUser) => updateCredentialResolver(params, req)
|
||||||
|
};
|
||||||
|
|
||||||
|
export default updateCredential;
|
@@ -1,12 +1,14 @@
|
|||||||
import { GraphQLObjectType } from 'graphql';
|
import { GraphQLObjectType } from 'graphql';
|
||||||
import createCredential from './mutations/create-credential';
|
import createCredential from './mutations/create-credential';
|
||||||
import createAuthLink from './mutations/create-auth-link';
|
import createAuthLink from './mutations/create-auth-link';
|
||||||
|
import updateCredential from './mutations/update-credential';
|
||||||
|
|
||||||
const rootMutation = new GraphQLObjectType({
|
const rootMutation = new GraphQLObjectType({
|
||||||
name: 'Mutation',
|
name: 'Mutation',
|
||||||
fields: {
|
fields: {
|
||||||
createCredential: createCredential,
|
createCredential: createCredential,
|
||||||
createAuthLink: createAuthLink
|
createAuthLink: createAuthLink,
|
||||||
|
updateCredential: updateCredential
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
import { GraphQLObjectType, GraphQLString } from 'graphql';
|
import { GraphQLObjectType, GraphQLString, GraphQLBoolean } from 'graphql';
|
||||||
import twitterCredentialType from './twitter-credential';
|
import twitterCredentialType from './twitter-credential';
|
||||||
|
|
||||||
const credentialType = new GraphQLObjectType({
|
const credentialType = new GraphQLObjectType({
|
||||||
@@ -7,6 +7,7 @@ const credentialType = new GraphQLObjectType({
|
|||||||
id: { type: GraphQLString },
|
id: { type: GraphQLString },
|
||||||
key: { type: GraphQLString },
|
key: { type: GraphQLString },
|
||||||
data: { type: twitterCredentialType },
|
data: { type: twitterCredentialType },
|
||||||
|
verified: { type: GraphQLBoolean },
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@@ -5,6 +5,7 @@ const twitterCredentialInputType = new GraphQLInputObjectType({
|
|||||||
fields: {
|
fields: {
|
||||||
consumerKey: { type: GraphQLString },
|
consumerKey: { type: GraphQLString },
|
||||||
consumerSecret: { type: GraphQLString },
|
consumerSecret: { type: GraphQLString },
|
||||||
|
oauthVerifier: { type: GraphQLString },
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@@ -4,8 +4,9 @@ import User from './user'
|
|||||||
class Credential extends Base {
|
class Credential extends Base {
|
||||||
id!: number
|
id!: number
|
||||||
key!: string
|
key!: string
|
||||||
data!: string
|
data!: any
|
||||||
userId!: number
|
userId!: number
|
||||||
|
verified: boolean
|
||||||
|
|
||||||
static tableName = 'credentials';
|
static tableName = 'credentials';
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user