-
Notifications
You must be signed in to change notification settings - Fork 10
/
Queue.tsx
136 lines (118 loc) · 3.12 KB
/
Queue.tsx
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
import * as React from "react";
import { Queue as Entity, IQueueState as Data } from "@daostack/arc.js";
import {
Arc as Protocol,
ArcConfig as ProtocolConfig,
Component,
ComponentLogs,
ComponentProps,
DAO,
DAOEntity,
} from "../";
import { CreateContextFeed } from "../runtime/ContextFeed";
interface RequiredProps extends ComponentProps<Entity, Data> {
// Address of the Queue Avatar
id: string;
dao?: string | DAOEntity;
}
interface InferredProps extends RequiredProps {
config: ProtocolConfig;
}
class InferredQueue extends Component<InferredProps, Entity, Data> {
protected createEntity(): Entity {
const { config, id, dao } = this.props;
if (!config) {
throw Error(
"Arc Config Missing: Please provide this field as a prop, or use the inference component."
);
}
if (!dao) {
throw Error(
"DAO Missing: Please provide this field as a prop, or use the inference component."
);
}
const daoEntity: DAOEntity =
typeof dao === "string" ? new DAOEntity(config.connection, dao) : dao;
return new Entity(config.connection, id, daoEntity);
}
public static get Entity() {
return CreateContextFeed(
this.EntityContext.Consumer,
this.LogsContext.Consumer,
"Queue"
);
}
public static get Data() {
return CreateContextFeed(
this.DataContext.Consumer,
this.LogsContext.Consumer,
"Queue"
);
}
public static get Logs() {
return CreateContextFeed(
this.LogsContext.Consumer,
this.LogsContext.Consumer,
"Queue"
);
}
public static EntityContext = React.createContext<Entity | undefined>(
undefined
);
public static DataContext = React.createContext<Data | undefined>(undefined);
public static LogsContext = React.createContext<ComponentLogs | undefined>(
undefined
);
}
function useQueue(): [Data | undefined, Entity | undefined] {
const data = React.useContext<Data | undefined>(InferredQueue.DataContext);
const entity = React.useContext<Entity | undefined>(
InferredQueue.EntityContext
);
return [data, entity];
}
class Queue extends React.Component<RequiredProps> {
public render() {
const { id, children, dao } = this.props;
return (
<Protocol.Config>
{(config: ProtocolConfig) => {
if (dao) {
return (
<InferredQueue id={id} dao={dao} config={config}>
{children}
</InferredQueue>
);
} else {
return (
<DAO.Entity>
{(entity: DAOEntity) => (
<InferredQueue id={id} dao={entity} config={config}>
{children}
</InferredQueue>
)}
</DAO.Entity>
);
}
}}
</Protocol.Config>
);
}
public static get Entity() {
return InferredQueue.Entity;
}
public static get Data() {
return InferredQueue.Data;
}
public static get Logs() {
return InferredQueue.Logs;
}
}
export default Queue;
export {
Queue,
InferredQueue,
Entity as QueueEntity,
Data as QueueData,
useQueue,
};