From 037f19580336c3e6428b5569234edf5538e8d15b Mon Sep 17 00:00:00 2001
From: krateng <git.noreply@krateng.ch>
Date: Fri, 8 Apr 2022 04:52:59 +0200
Subject: [PATCH] More normalizing

---
 maloja/database/__init__.py                  |  2 +-
 maloja/proccontrol/tasks/import_scrobbles.py | 58 ++++++++++----------
 2 files changed, 30 insertions(+), 30 deletions(-)

diff --git a/maloja/database/__init__.py b/maloja/database/__init__.py
index b1bad3d..6de6bba 100644
--- a/maloja/database/__init__.py
+++ b/maloja/database/__init__.py
@@ -113,7 +113,7 @@ def incoming_scrobble(rawscrobble,fix=True,client=None,api=None,dbconn=None):
 			"length":scrobbleinfo.get('track_length')
 		},
 		"duration":scrobbleinfo.get('scrobble_duration'),
-		"origin":f"client: {client}" if client else "generic",
+		"origin":f"client:{client}" if client else "generic",
 		"extra":{
 			k:scrobbleinfo[k] for k in scrobbleinfo if k not in
 			['scrobble_time','track_artists','track_title','track_length','scrobble_duration','album_name','album_artists']
diff --git a/maloja/proccontrol/tasks/import_scrobbles.py b/maloja/proccontrol/tasks/import_scrobbles.py
index b068070..5e9f1cf 100644
--- a/maloja/proccontrol/tasks/import_scrobbles.py
+++ b/maloja/proccontrol/tasks/import_scrobbles.py
@@ -64,27 +64,27 @@ def import_scrobbles(inputf):
 		if status in ['CONFIDENT_IMPORT','UNCERTAIN_IMPORT']:
 
 			# prevent duplicate timestamps
-			while scrobble['timestamp'] in timestamps:
-				scrobble['timestamp'] += 1
-			timestamps.add(scrobble['timestamp'])
+			while scrobble['scrobble_time'] in timestamps:
+				scrobble['scrobble_time'] += 1
+			timestamps.add(scrobble['scrobble_time'])
 
 			# clean up
-			(scrobble['artists'],scrobble['title']) = c.fullclean(scrobble['artists'],scrobble['title'])
+			(scrobble['track_artists'],scrobble['track_title']) = c.fullclean(scrobble['track_artists'],scrobble['track_title'])
 
 			# extra info
 			extrainfo = {}
-			if scrobble.get('album'): extrainfo['album_name'] = scrobble['album']
+			if scrobble.get('album_name'): extrainfo['album_name'] = scrobble['album_name']
 			# saving this in the scrobble instead of the track because for now it's not meant
 			# to be authorative information, just payload of the scrobble
 
 			scrobblebuffer.append({
-				"time":scrobble['timestamp'],
+				"time":scrobble['scrobble_time'],
 				 	"track":{
-				 		"artists":scrobble['artists'],
-				 		"title":scrobble['title'],
+				 		"artists":scrobble['track_artists'],
+				 		"title":scrobble['track_title'],
 				 		"length":None
 				 	},
-				 	"duration":scrobble['duration'],
+				 	"duration":scrobble['scrobble_duration'],
 				 	"origin":"import:" + typeid,
 					"extra":extrainfo
 			})
@@ -145,11 +145,11 @@ def parse_spotify_lite(inputf):
 					continue
 
 				yield ("CONFIDENT_IMPORT",{
-					'title':title,
-					'artists': artist,
-					'timestamp': timestamp,
-					'duration':played,
-					'album': None
+					'track_title':title,
+					'track_artists': artist,
+					'scrobble_time': timestamp,
+					'scrobble_duration':played,
+					'album_name': None
 				},'')
 			except Exception as e:
 				yield ('FAIL',None,f"{entry} could not be parsed. Scrobble not imported. ({repr(e)})")
@@ -249,11 +249,11 @@ def parse_spotify_full(inputf):
 
 
 				yield (status,{
-					'title':title,
-					'artists': artist,
-					'album': album,
-					'timestamp': timestamp,
-					'duration':played
+					'track_title':title,
+					'track_artists': artist,
+					'album_name': album,
+					'scrobble_time': timestamp,
+					'scrobble_duration':played
 				},msg)
 			except Exception as e:
 				yield ('FAIL',None,f"{entry} could not be parsed. Scrobble not imported. ({repr(e)})")
@@ -275,14 +275,14 @@ def parse_lastfm(inputf):
 
 			try:
 				yield ('CONFIDENT_IMPORT',{
-					'title': title,
-					'artists': artist,
-					'album': album,
-					'timestamp': int(datetime.datetime.strptime(
+					'track_title': title,
+					'track_artists': artist,
+					'album_name': album,
+					'scrobble_time': int(datetime.datetime.strptime(
 						time + '+0000',
 						"%d %b %Y %H:%M%z"
 					).timestamp()),
-					'duration':None
+					'scrobble_duration':None
 				},'')
 			except Exception as e:
 				yield ('FAIL',None,f"{entry} could not be parsed. Scrobble not imported. ({repr(e)})")
@@ -299,11 +299,11 @@ def parse_maloja(inputf):
 	for s in scrobbles:
 		try:
 			yield ('CONFIDENT_IMPORT',{
-				'title': s['track']['title'],
-				'artists': s['track']['artists'],
-				'album': s['track'].get('album',{}).get('name',''),
-				'timestamp': s['time'],
-				'duration': s['duration']
+				'track_title': s['track']['title'],
+				'track_artists': s['track']['artists'],
+				'album_name': s['track'].get('album',{}).get('name',''),
+				'scrobble_time': s['time'],
+				'scrobble_duration': s['duration']
 			},'')
 		except Exception as e:
 			yield ('FAIL',None,f"{s} could not be parsed. Scrobble not imported. ({repr(e)})")