@@ -20,7 +20,7 @@ function checkStatus() {
2020 . subtract ( 1 , 'hour' )
2121
2222 var filename = 'file_date=' + time . format ( 'YYYYMMDD' ) +
23- '/XBT|USD/ STMP/' + time . format ( 'HH' ) + '.csv'
23+ '/pair=XBT_USD/source= STMP/' + time . format ( 'HH' ) + '.csv'
2424
2525 console . log ( 'checking for file: ' + filename )
2626
@@ -34,10 +34,10 @@ function checkStatus() {
3434 * appendFile
3535 */
3636
37- function appendFile ( pair , market , time , data ) {
37+ function appendFile ( pair , source , time , data ) {
3838 var filename = 'file_date=' + time . format ( 'YYYYMMDD' ) +
39- '/' + pair . replace ( '/' , '| ' ) +
40- '/' + market +
39+ '/pair= ' + pair . replace ( '/' , '_ ' ) +
40+ '/source= ' + source +
4141 '/' + time . format ( 'HH' ) + '.csv'
4242 console . log ( 'appending file: ' + filename )
4343
@@ -57,15 +57,15 @@ function appendFile(pair, market, time, data) {
5757 */
5858
5959function saveBuffer ( time ) {
60- var market
60+ var source
6161 var pair
6262
6363 console . log ( 'save buffer' )
6464
6565 for ( pair in buffer ) {
66- for ( market in buffer [ pair ] ) {
67- appendFile ( pair , market , time , buffer [ pair ] [ market ] )
68- delete buffer [ pair ] [ market ]
66+ for ( source in buffer [ pair ] ) {
67+ appendFile ( pair , source , time , buffer [ pair ] [ source ] )
68+ delete buffer [ pair ] [ source ]
6969 }
7070 }
7171
0 commit comments