Function
deployPipes
({
spinner,
pipes,
pipesDir,
account
}: {
spinner: Spinner;
pipes: string[];
pipesDir: string;
account: Account;
})
Source from the content-addressed store, hash-verified
| 160 | } |
| 161 | |
| 162 | async function deployPipes({ |
| 163 | spinner, |
| 164 | pipes, |
| 165 | pipesDir, |
| 166 | account |
| 167 | }: { |
| 168 | spinner: Spinner; |
| 169 | pipes: string[]; |
| 170 | pipesDir: string; |
| 171 | account: Account; |
| 172 | }): Promise<void> { |
| 173 | for (const pipe of pipes) { |
| 174 | if (path.extname(pipe) === '.json') { |
| 175 | await new Promise(resolve => setTimeout(resolve, 500)); // To avoid rate limiting |
| 176 | await deployPipe({ spinner, pipe, pipesDir, account }); |
| 177 | } |
| 178 | } |
| 179 | } |
| 180 | |
| 181 | async function deployPipe({ |
| 182 | spinner, |
Tested by
no test coverage detected