c2 api calls now per own api

rowers/tasks.py

@@ -2710,6 +2710,169 @@ def handle_sendemail_invite_accept(email, name, teamname, managername,
 def add2(x, y,debug=False,**kwargs):
     return x + y
 
+@app.task
+def handle_c2_async_workout(alldata,userid,c2token,c2id,debug=False,**kwargs):
+    data = alldata[c2id]
+    splitdata = None
+
+    distance = data['distance']
+    c2id = data['id']
+    workouttype = data['type']
+    verified = data['verified']
+    startdatetime = iso8601.parse_date(data['date'])
+    weightclass = data['weight_class']
+
+    try:
+        title = data['name']
+    except KeyError:
+        title = ""
+        try:
+            t = data['comments'].split('\n', 1)[0]
+            title += t[:40]
+        except:
+            title = 'Imported'
+
+    weightcategory = 'hwt'
+    if weightclass == "L":
+        weightcategory = 'lwt'
+
+    # Create CSV file name and save data to CSV file
+    csvfilename ='media/Import_'+str(c2id)+'.csv.gz'
+
+    totaltime = data['time']/10.
+    duration = totaltime_sec_to_string(totaltime)
+
+    try:
+        timezone_str = tz(data['timezone'])
+    except:
+        timezone_str = 'UTC'
+
+    workoutdate = startdatetime.astimezone(
+        pytz.timezone(timezone_str)
+    ).strftime('%Y-%m-%d')
+    starttime = startdatetime.astimezone(
+        pytz.timezone(timezone_str)
+    ).strftime('%H:%M:%S')
+
+    try:
+        notes = data['comments']
+        name = notes[:40]
+    except (KeyError,TypeError):
+        notes = 'C2 Import Workout from {startdatetime}'.format(startdatetime=startdatetime)
+        name = notes
+
+    authorizationstring = str('Bearer ' + c2token)
+    headers = {'Authorization': authorizationstring,
+           'user-agent': 'sanderroosendaal',
+           'Content-Type': 'application/json'}
+    url = "https://log.concept2.com/api/users/me/results/"+str(c2id)+"/strokes"
+    try:
+        s = requests.get(url,headers=headers)
+    except ConnectionError:
+        return 0
+
+    if s.status_code != 200:
+        return 0
+
+    strokedata = pd.DataFrame.from_dict(s.json()['data'])
+
+    res = make_cumvalues(0.1*strokedata['t'])
+    cum_time = res[0]
+    lapidx = res[1]
+
+    starttimeunix = arrow.get(startdatetime).timestamp
+
+    unixtime = cum_time+starttimeunix
+    # unixtime[0] = starttimeunix
+    seconds = 0.1*strokedata.loc[:,'t']
+
+    nr_rows = len(unixtime)
+
+    try:
+        latcoord = strokedata.loc[:,'lat']
+        loncoord = strokedata.loc[:,'lon']
+    except:
+        latcoord = np.zeros(nr_rows)
+        loncoord = np.zeros(nr_rows)
+
+
+    try:
+        strokelength = strokedata.loc[:,'strokelength']
+    except:
+        strokelength = np.zeros(nr_rows)
+
+    dist2 = 0.1*strokedata.loc[:,'d']
+
+    try:
+        spm = strokedata.loc[:,'spm']
+    except KeyError:
+        spm = 0*dist2
+
+    try:
+        hr = strokedata.loc[:,'hr']
+    except KeyError:
+        hr = 0*spm
+
+    pace = strokedata.loc[:,'p']/10.
+    pace = np.clip(pace,0,1e4)
+    pace = pace.replace(0,300)
+
+    velo = 500./pace
+    power = 2.8*velo**3
+    if workouttype == 'bike':
+        velo = 1000./pace
+
+    df = pd.DataFrame({'TimeStamp (sec)':unixtime,
+                       ' Horizontal (meters)': dist2,
+                       ' Cadence (stokes/min)':spm,
+                       ' HRCur (bpm)':hr,
+                       ' longitude':loncoord,
+                       ' latitude':latcoord,
+                       ' Stroke500mPace (sec/500m)':pace,
+                       ' Power (watts)':power,
+                       ' DragFactor':np.zeros(nr_rows),
+                       ' DriveLength (meters)':np.zeros(nr_rows),
+                       ' StrokeDistance (meters)':strokelength,
+                       ' DriveTime (ms)':np.zeros(nr_rows),
+                       ' StrokeRecoveryTime (ms)':np.zeros(nr_rows),
+                       ' AverageDriveForce (lbs)':np.zeros(nr_rows),
+                       ' PeakDriveForce (lbs)':np.zeros(nr_rows),
+                       ' lapIdx':lapidx,
+                       ' WorkoutState': 4,
+                       ' ElapsedTime (sec)':seconds,
+                       'cum_dist': dist2
+                       })
+
+
+    df.sort_values(by='TimeStamp (sec)',ascending=True)
+
+    res =  df.to_csv(csvfilename,index_label='index',
+                     compression='gzip')
+
+    uploadoptions = {
+        'secret':UPLOAD_SERVICE_SECRET,
+        'user':userid,
+        'file': csvfilename,
+        'title': title,
+        'workouttype':workouttype,
+        'boattype':'1x',
+        'c2id':c2id,
+    }
+
+    session = requests.session()
+    newHeaders = {'Content-type': 'application/json', 'Accept': 'text/plain'}
+    session.headers.update(newHeaders)
+
+    response = session.post(UPLOAD_SERVICE_URL,json=uploadoptions)
+
+    if response.status_code != 200:
+        return 0
+
+    workoutid = response.json()['id']
+
+    return workoutid
+
+
 @app.task
 def fetch_strava_workout(stravatoken,oauth_data,stravaid,csvfilename,userid,debug=False,**kwargs):
     fetchresolution = 'high'