114
115
116
117
118
119
120
121
122
123
124
125
126
127
128 | 114
115
116
117
118
119
120
121
122
123
124
125
126
127
128 |
-
+
|
# add event to list
def queue(self, row):
# chk
if not row.get(self.timefield) or not row.get("url"):
#print("NO TIME DATA", row)
#log.DATA("NO TIME DATA", row)
return
# extract timing parameters
_ = row[self.timefield]
days = self.days(_)
time = self.time(_)
duration = self.duration(_) |
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199 | 172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199 |
-
+
-
+
| url = row["url"],
audioformat = row.get("format","audio/mpeg"),
listformat = row.get("listformat","href"),
)
# action wrapper
def record(self, row, *args, **kwargs):
#print("TIMED RECORD")
#log.TIMER("TIMED RECORD", *args)
# extra params
duration = self.duration(row.get(self.timefield))
if duration:
append = " -a %S.%d.%q -l "+str(duration*60) # make streamripper record a whole broadcast
else:
append = ""
# start recording
action.record(
url = row["url"],
audioformat = row.get("format","audio/mpeg"),
listformat = row.get("listformat","href"),
append = append,
)
def test(self, row, *args, **kwargs):
print("TEST KRONOS", row)
log.TEST("KRONOS", row)
|