Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitb887e31

Browse files
committed
feat: addbindAsyncAction helper forredux-saga
1 parenta022f66 commitb887e31

File tree

17 files changed

+2418
-39
lines changed

17 files changed

+2418
-39
lines changed

‎.gitignore‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,6 @@
55
# NPM
66
node_modules
77
npm-*.log
8-
yarn.lock
9-
10-
tests-build
118

129
# OS X
1310
.DS_Store

‎.travis.yml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,5 +5,5 @@ node_js:
55

66
script:
77
-npm run lint
8-
-npm run build
98
-npm test
9+
-npm run build
File renamed without changes.

‎es/index.js‎

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
exportfunctionisType(action,actionCreator){
2+
returnaction.type===actionCreator.type;
3+
}
4+
exportdefaultfunctionactionCreatorFactory(prefix,defaultIsError=p=>pinstanceofError){
5+
constactionTypes={};
6+
constbase=prefix ?`${prefix}/` :"";
7+
functionactionCreator(type,commonMeta,isError=defaultIsError){
8+
constfullType=base+type;
9+
if(process.env.NODE_ENV!=='production'){
10+
if(actionTypes[fullType])
11+
thrownewError(`Duplicate action type:${fullType}`);
12+
actionTypes[fullType]=true;
13+
}
14+
returnObject.assign((payload,meta)=>{
15+
constaction={
16+
type:fullType,
17+
payload,
18+
};
19+
if(commonMeta||meta){
20+
action.meta=Object.assign({},commonMeta,meta);
21+
}
22+
if(isError&&(typeofisError==='boolean'||isError(payload))){
23+
action.error=true;
24+
}
25+
returnaction;
26+
},{type:fullType});
27+
}
28+
functionasyncActionCreators(type,commonMeta){
29+
return{
30+
type:base+type,
31+
started:actionCreator(`${type}_STARTED`,commonMeta,false),
32+
done:actionCreator(`${type}_DONE`,commonMeta,false),
33+
failed:actionCreator(`${type}_FAILED`,commonMeta,true),
34+
};
35+
}
36+
returnObject.assign(actionCreator,{async:asyncActionCreators});
37+
}

‎es/sagas.d.ts‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
import{AsyncActionCreators}from"./index";
2+
import{SagaIterator}from"redux-saga";
3+
exportdeclarefunctionbindAsyncAction<R>(actionCreators:AsyncActionCreators<void,R,any>):{
4+
(worker:()=>Promise<R>|SagaIterator):()=>SagaIterator;
5+
(worker:(params:void)=>Promise<R>|SagaIterator):(params:void)=>SagaIterator;
6+
<A1>(worker:(params:void,arg1:A1)=>Promise<R>|SagaIterator):(params:void,arg1:A1)=>SagaIterator;
7+
<A1,A2>(worker:(params:void,arg1:A1,arg2:A2)=>Promise<R>|SagaIterator):(params:void,arg1:A1,arg2:A2)=>SagaIterator;
8+
<A1,A2,A3>(worker:(params:void,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>Promise<R>|SagaIterator):(params:void,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>SagaIterator;
9+
};
10+
exportdeclarefunctionbindAsyncAction<P,R>(actionCreators:AsyncActionCreators<P,R,any>):{
11+
(worker:(params:P)=>Promise<R>|SagaIterator):(params:P)=>SagaIterator;
12+
<A1>(worker:(params:P,arg1:A1)=>Promise<R>|SagaIterator):(params:P,arg1:A1)=>SagaIterator;
13+
<A1,A2>(worker:(params:P,arg1:A1,arg2:A2)=>Promise<R>|SagaIterator):(params:P,arg1:A1,arg2:A2)=>SagaIterator;
14+
<A1,A2,A3>(worker:(params:P,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>Promise<R>|SagaIterator):(params:P,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>SagaIterator;
15+
};

‎es/sagas.js‎

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
import{put,call,cancelled}from"redux-saga/effects";
2+
exportfunctionbindAsyncAction(actionCreator){
3+
return(worker)=>{
4+
function*boundAsyncActionSaga(params, ...args){
5+
yieldput(actionCreator.started(params));
6+
try{
7+
constresult=yieldcall(worker,params, ...args);
8+
yieldput(actionCreator.done({ params, result}));
9+
returnresult;
10+
}
11+
catch(error){
12+
yieldput(actionCreator.failed({ params, error}));
13+
throwerror;
14+
}
15+
finally{
16+
if(yieldcancelled()){
17+
yieldput(actionCreator.failed({ params,error:'cancelled'}));
18+
}
19+
}
20+
}
21+
constcapName=worker.name.charAt(0).toUpperCase()+
22+
worker.name.substring(1);
23+
returnsetFunctionName(boundAsyncActionSaga,`bound${capName}(${actionCreator.type})`);
24+
};
25+
}
26+
/**
27+
* Set function name.
28+
*
29+
* Note that this won't have effect on built-in Chrome stack traces, although
30+
* useful for traces generated by `redux-saga`.
31+
*/
32+
functionsetFunctionName(func,name){
33+
try{
34+
Object.defineProperty(func,'name',{
35+
value:name,
36+
configurable:true,
37+
});
38+
}
39+
catch(e){
40+
}
41+
returnfunc;
42+
}

‎lib/index.d.ts‎

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
import{ActionasReduxAction}from"redux";
2+
exportinterfaceAction<P>extendsReduxAction{
3+
type:string;
4+
payload:P;
5+
error?:boolean;
6+
meta?:Object;
7+
}
8+
exportinterfaceSuccess<P,S>{
9+
params:P;
10+
result:S;
11+
}
12+
exportinterfaceFailure<P,E>{
13+
params:P;
14+
error:E;
15+
}
16+
exportdeclarefunctionisType<P>(action:ReduxAction,actionCreator:ActionCreator<P>):action isAction<P>;
17+
exportinterfaceActionCreator<P>{
18+
type:string;
19+
(payload:P,meta?:Object):Action<P>;
20+
}
21+
exportinterfaceEmptyActionCreatorextendsActionCreator<undefined>{
22+
(payload?:undefined,meta?:Object):Action<undefined>;
23+
}
24+
exportinterfaceAsyncActionCreators<P,S,E>{
25+
type:string;
26+
started:ActionCreator<P>;
27+
done:ActionCreator<Success<P,S>>;
28+
failed:ActionCreator<Failure<P,E>>;
29+
}
30+
exportinterfaceActionCreatorFactory{
31+
(type:string,commonMeta?:Object,error?:boolean):EmptyActionCreator;
32+
<P>(type:string,commonMeta?:Object,isError?:boolean):ActionCreator<P>;
33+
<P>(type:string,commonMeta?:Object,isError?:(payload:P)=>boolean):ActionCreator<P>;
34+
async<P,S>(type:string,commonMeta?:Object):AsyncActionCreators<P,S,any>;
35+
async<P,S,E>(type:string,commonMeta?:Object):AsyncActionCreators<P,S,E>;
36+
}
37+
exportdefaultfunctionactionCreatorFactory(prefix?:string,defaultIsError?:(payload:any)=>boolean):ActionCreatorFactory;

‎lib/index.js‎

Lines changed: 22 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1,24 +1,32 @@
1-
"use strict";
1+
'use strict';
2+
3+
Object.defineProperty(exports,"__esModule",{
4+
value:true
5+
});
6+
exports.isType=isType;
7+
exports.default=actionCreatorFactory;
28
functionisType(action,actionCreator){
39
returnaction.type===actionCreator.type;
410
}
5-
exports.isType=isType;
6-
functionactionCreatorFactory(prefix,defaultIsError){
7-
if(defaultIsError===void0){defaultIsError=function(p){returnpinstanceofError;};}
11+
functionactionCreatorFactory(prefix){
12+
vardefaultIsError=arguments.length>1&&arguments[1]!==undefined ?arguments[1] :function(p){
13+
returnpinstanceofError;
14+
};
15+
816
varactionTypes={};
9-
varbase=prefix ?prefix+"/" :"";
10-
functionactionCreator(type,commonMeta,isError){
11-
if(isError===void0){isError=defaultIsError;}
17+
varbase=prefix ?prefix+'/' :"";
18+
functionactionCreator(type,commonMeta){
19+
varisError=arguments.length>2&&arguments[2]!==undefined ?arguments[2] :defaultIsError;
20+
1221
varfullType=base+type;
1322
if(process.env.NODE_ENV!=='production'){
14-
if(actionTypes[fullType])
15-
thrownewError("Duplicate action type: "+fullType);
23+
if(actionTypes[fullType])thrownewError('Duplicate action type: '+fullType);
1624
actionTypes[fullType]=true;
1725
}
1826
returnObject.assign(function(payload,meta){
1927
varaction={
2028
type:fullType,
21-
payload:payload,
29+
payload:payload
2230
};
2331
if(commonMeta||meta){
2432
action.meta=Object.assign({},commonMeta,meta);
@@ -32,12 +40,10 @@ function actionCreatorFactory(prefix, defaultIsError) {
3240
functionasyncActionCreators(type,commonMeta){
3341
return{
3442
type:base+type,
35-
started:actionCreator(type+"_STARTED",commonMeta,false),
36-
done:actionCreator(type+"_DONE",commonMeta,false),
37-
failed:actionCreator(type+"_FAILED",commonMeta,true),
43+
started:actionCreator(type+'_STARTED',commonMeta,false),
44+
done:actionCreator(type+'_DONE',commonMeta,false),
45+
failed:actionCreator(type+'_FAILED',commonMeta,true)
3846
};
3947
}
4048
returnObject.assign(actionCreator,{async:asyncActionCreators});
41-
}
42-
Object.defineProperty(exports,"__esModule",{value:true});
43-
exports.default=actionCreatorFactory;
49+
}

‎lib/sagas.d.ts‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
import{AsyncActionCreators}from"./index";
2+
import{SagaIterator}from"redux-saga";
3+
exportdeclarefunctionbindAsyncAction<R>(actionCreators:AsyncActionCreators<void,R,any>):{
4+
(worker:()=>Promise<R>|SagaIterator):()=>SagaIterator;
5+
(worker:(params:void)=>Promise<R>|SagaIterator):(params:void)=>SagaIterator;
6+
<A1>(worker:(params:void,arg1:A1)=>Promise<R>|SagaIterator):(params:void,arg1:A1)=>SagaIterator;
7+
<A1,A2>(worker:(params:void,arg1:A1,arg2:A2)=>Promise<R>|SagaIterator):(params:void,arg1:A1,arg2:A2)=>SagaIterator;
8+
<A1,A2,A3>(worker:(params:void,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>Promise<R>|SagaIterator):(params:void,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>SagaIterator;
9+
};
10+
exportdeclarefunctionbindAsyncAction<P,R>(actionCreators:AsyncActionCreators<P,R,any>):{
11+
(worker:(params:P)=>Promise<R>|SagaIterator):(params:P)=>SagaIterator;
12+
<A1>(worker:(params:P,arg1:A1)=>Promise<R>|SagaIterator):(params:P,arg1:A1)=>SagaIterator;
13+
<A1,A2>(worker:(params:P,arg1:A1,arg2:A2)=>Promise<R>|SagaIterator):(params:P,arg1:A1,arg2:A2)=>SagaIterator;
14+
<A1,A2,A3>(worker:(params:P,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>Promise<R>|SagaIterator):(params:P,arg1:A1,arg2:A2,arg3:A3, ...rest:any[])=>SagaIterator;
15+
};

‎lib/sagas.js‎

Lines changed: 97 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,97 @@
1+
'use strict';
2+
3+
Object.defineProperty(exports,"__esModule",{
4+
value:true
5+
});
6+
exports.bindAsyncAction=bindAsyncAction;
7+
8+
var_effects=require('redux-saga/effects');
9+
10+
functionbindAsyncAction(actionCreator){
11+
returnfunction(worker){
12+
var_marked=[boundAsyncActionSaga].map(regeneratorRuntime.mark);
13+
14+
functionboundAsyncActionSaga(params){
15+
var_len,
16+
args,
17+
_key,
18+
result,
19+
_args=arguments;
20+
21+
returnregeneratorRuntime.wrap(functionboundAsyncActionSaga$(_context){
22+
while(1){
23+
switch(_context.prev=_context.next){
24+
case0:
25+
_context.next=2;
26+
return(0,_effects.put)(actionCreator.started(params));
27+
28+
case2:
29+
_context.prev=2;
30+
31+
for(_len=_args.length,args=Array(_len>1 ?_len-1 :0),_key=1;_key<_len;_key++){
32+
args[_key-1]=_args[_key];
33+
}
34+
35+
_context.next=6;
36+
return_effects.call.apply(undefined,[worker,params].concat(args));
37+
38+
case6:
39+
result=_context.sent;
40+
_context.next=9;
41+
return(0,_effects.put)(actionCreator.done({params:params,result:result}));
42+
43+
case9:
44+
return_context.abrupt('return',result);
45+
46+
case12:
47+
_context.prev=12;
48+
_context.t0=_context['catch'](2);
49+
_context.next=16;
50+
return(0,_effects.put)(actionCreator.failed({params:params,error:_context.t0}));
51+
52+
case16:
53+
throw_context.t0;
54+
55+
case17:
56+
_context.prev=17;
57+
_context.next=20;
58+
return(0,_effects.cancelled)();
59+
60+
case20:
61+
if(!_context.sent){
62+
_context.next=23;
63+
break;
64+
}
65+
66+
_context.next=23;
67+
return(0,_effects.put)(actionCreator.failed({params:params,error:'cancelled'}));
68+
69+
case23:
70+
return_context.finish(17);
71+
72+
case24:
73+
case'end':
74+
return_context.stop();
75+
}
76+
}
77+
},_marked[0],this,[[2,12,17,24]]);
78+
}
79+
varcapName=worker.name.charAt(0).toUpperCase()+worker.name.substring(1);
80+
returnsetFunctionName(boundAsyncActionSaga,'bound'+capName+'('+actionCreator.type+')');
81+
};
82+
}
83+
/**
84+
* Set function name.
85+
*
86+
* Note that this won't have effect on built-in Chrome stack traces, although
87+
* useful for traces generated by `redux-saga`.
88+
*/
89+
functionsetFunctionName(func,name){
90+
try{
91+
Object.defineProperty(func,'name',{
92+
value:name,
93+
configurable:true
94+
});
95+
}catch(e){}
96+
returnfunc;
97+
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp