client/src/activities_view.vala

@@ -1,31 +1,59 @@
 namespace StudySystemClient {
-	public class ActivitiesView : CardArea<ActivityCard>, IRefreshable {
+	public class ActivitiesView : Gtk.Box {
-		private const uint REFRESH_PERIOD_MS = 30000;
-
 		private Client client;
-		private Refresher refresher;
+		private Gtk.FlowBox card_container;
-		private bool pending_sort;
+		private RefreshingIndicator refreshing_indicator;
 
 		public ActivitiesView(Client client)  {
+			Object(orientation: Gtk.Orientation.VERTICAL,
+				   hexpand: true,
+				   vexpand: true,
+				   margin_top: 0,
+				   margin_bottom: 0,
+				   margin_start: 0,
+				   margin_end: 0);
+
 			this.client = client;
-			refresher = new Refresher(this, REFRESH_PERIOD_MS);
+
-			pending_sort = false;
+			card_container = new Gtk.FlowBox();
-			this.map.connect(() => {
+			card_container.homogeneous = true;
-					refresher.start();
+			card_container.min_children_per_line = 1;
-					refresh.begin();
+			card_container.max_children_per_line = 1;
-				});
+			card_container.selection_mode = Gtk.SelectionMode.NONE;
+			card_container.valign = Gtk.Align.START;
+
+			var scrolled_window = new Gtk.ScrolledWindow();
+			scrolled_window.hscrollbar_policy = Gtk.PolicyType.NEVER;
+			scrolled_window.hexpand = true;
+			scrolled_window.vexpand = true;
+			scrolled_window.add_css_class("card-container");
+			scrolled_window.set_child(card_container);
+
+			var overlay = new Gtk.Overlay();
+			overlay.hexpand = overlay.vexpand = true;
+			overlay.set_child(scrolled_window);
+			this.append(overlay);
+
+			refreshing_indicator = new RefreshingIndicator(overlay);
+
+			this.map.connect(refresh);
 		}
 
 		private async void refresh() {
-			if (!client.connected)
+			refreshing_indicator.show();
-				return;
 			try {
 				var activities = yield client.list_activities();
-				update_cards(activities);
+				card_container.remove_all();
+				foreach (var activity in activities) {
+					var card = new ActivityCard(activity);
+					card.session_logged.connect(log_session);
+					card_container.append(card);
+				}
 			} catch (ClientError e) {
 				stderr.printf("Error refreshing activities: %s\n",
 							  e.message);
 			}
+			refreshing_indicator.hide();
 		}
 
 		private async void log_session(string subject, ActivityType type,
@@ -37,78 +65,43 @@ namespace StudySystemClient {
 				stderr.printf("Error logging session: %s\n", e.message);
 			}
 		}
-
-		private void handle_pending_sort() {
-			if (pending_sort) {
-				container.sort(compare_cards);
-				pending_sort = false;
-			}
 	}
 
-		private void update_cards(Array<Activity> activities) {
+	private class RefreshingIndicator {
-			update_existing_cards(activities);
+		private Gtk.Overlay overlay;
-			for (uint i = 0; i < activities.length; ++i)
+		private Gtk.Frame frame;
-				create_card(activities.index(i));
+
-			if (log_in_progress())
+		public RefreshingIndicator(Gtk.Overlay overlay) {
-				pending_sort = true;
+			this.overlay = overlay;
-			else
+
-				container.sort(compare_cards);
+			var label = new Gtk.Label("Refreshing");
+			label.halign = Gtk.Align.START;
+
+			var spinner = new Gtk.Spinner();
+			spinner.start();
+
+			var content = new Gtk.Box(Gtk.Orientation.HORIZONTAL, 6);
+			content.margin_top = content.margin_bottom
+				= content.margin_start = content.margin_end = 12;
+			content.append(label);
+			content.append(spinner);
+
+			frame = new Gtk.Frame(null);
+			frame.halign = Gtk.Align.CENTER;
+			frame.valign = Gtk.Align.START;
+			frame.add_css_class("osd");
+			frame.add_css_class("popdown");
+			frame.set_child(content);
+
+			overlay.add_overlay(frame);
 		}
 
-		private void update_existing_cards(Array<Activity> activities) {
+		public void show() {
-			var to_remove = new List<ActivityCard>();
+			frame.add_css_class("visible");
-			foreach (var card in container) {
-				if (!update_existing_card(card, activities))
-					to_remove.append(card);
-			}
-			foreach (var card in to_remove)
-				container.remove(card);
 		}
 
-		private bool update_existing_card(ActivityCard card,
+		public void hide() {
-										  Array<Activity> activities) {
+			frame.remove_css_class("visible");
-			var activity_index = find_activity(card, activities);
-			if (activity_index == null)
-				return false;
-			var priority = activities.index(activity_index).priority;
-			card.update_priority(priority);
-			activities._remove_index_fast(activity_index);
-			return true;
-		}
-
-		private uint? find_activity(ActivityCard card,
-									Array<Activity> activities) {
-			for (uint i = 0; i < activities.length; ++i) {
-				if (activities.index(i).subject == card.activity.subject
-					&& activities.index(i).type == card.activity.type)
-					return i;
-			}
-			return null;
-		}
-
-		private void create_card(Activity activity) {
-			var card = new ActivityCard(activity);
-			card.session_logged.connect(log_session);
-			card.log_closed.connect(handle_pending_sort);
-			container.append(card);
-		}
-
-		private bool log_in_progress() {
-			foreach (var card in container) {
-				if (card.logging)
-					return true;
-			}
-			return false;
-		}
-
-		private static int compare_cards(ActivityCard card1,
-										 ActivityCard card2) {
-			if (card1.activity.priority < card2.activity.priority)
-				return -1;
-			else if (card1.activity.priority > card2.activity.priority)
-				return 1;
-			else
-				return 0;
 		}
 	}
 }

client/src/activity_card.vala

@@ -1,19 +1,10 @@
 namespace StudySystemClient {
-	public class ActivityCard : Card {
+	public class ActivityCard : Gtk.Frame {
 		public signal void session_logged(string subject, ActivityType type,
 										  int minutes);
-		public signal void log_closed();
-
-		public Activity activity { get; private set; }
-		public bool logging { get; private set; }
-
-		private Gtk.Label priority_label;
 
 		public ActivityCard(Activity activity) {
-			base();
+			add_css_class("card");
-
-			this.activity = activity;
-			logging = false;
 
 			var subject = new Gtk.Label(activity.subject);
 			subject.halign = Gtk.Align.START;
@@ -23,14 +14,13 @@ namespace StudySystemClient {
 			type.add_css_class("activity-type");
 			var separator = new Gtk.Label("·");
 			separator.add_css_class("activity-priority");
-
+			var priority = new Gtk.Label("%0.2f".printf(activity.priority));
-			priority_label = new Gtk.Label(priority_text(activity.priority));
+			priority.add_css_class("activity-priority");
-			priority_label.add_css_class("activity-priority");
 
 			var details = new Gtk.Box(Gtk.Orientation.HORIZONTAL, 6);
 			details.append(type);
 			details.append(separator);
-			details.append(priority_label);
+			details.append(priority);
 
 			var text = new Gtk.Box(Gtk.Orientation.VERTICAL, 6);
 			text.hexpand = true;
@@ -52,27 +42,10 @@ namespace StudySystemClient {
 
 			var log_session_popover = new LogSessionPopover();
 			log_session_popover.set_parent(button);
-			log_session_popover.closed.connect(() => {
+			button.clicked.connect(() => log_session_popover.popup());
-					logging = false;
-					log_closed();
-				});
 			log_session_popover.session_logged.connect((minutes) => {
 					session_logged(activity.subject, activity.type, minutes);
 				});
-
-			button.clicked.connect(() => {
-					logging = true;
-					log_session_popover.popup();
-				});
-		}
-
-		public void update_priority(double new_priority) {
-			activity = { activity.subject, activity.type, new_priority };
-			priority_label.set_text(priority_text(new_priority));
-		}
-
-		private static string priority_text(double priority) {
-			return "%0.2f".printf(priority);
 		}
 	}
 

client/src/card.vala

@@ -1,28 +0,0 @@
-namespace StudySystemClient {
-	public class Card : Gtk.Frame {
-		public Card() {
-			hexpand = true;
-			add_css_class("card");
-		}
-	}
-
-	public class CardArea<T> : Gtk.Box {
-		protected IterableBox<T> container;
-
-		public CardArea() {
-			hexpand = vexpand = true;
-			margin_top = margin_bottom = margin_start = margin_end = 0;
-
-			container = new IterableBox<T>(Gtk.Orientation.VERTICAL, 6);
-			container.valign = Gtk.Align.START;
-
-			var scrolled_window = new Gtk.ScrolledWindow();
-			scrolled_window.hscrollbar_policy = Gtk.PolicyType.NEVER;
-			scrolled_window.hexpand = scrolled_window.vexpand = true;
-			scrolled_window.add_css_class("card-container");
-			scrolled_window.set_child(container);
-
-			append(scrolled_window);
-		}
-	}
-}

client/src/client.vala

@@ -5,16 +5,10 @@ namespace StudySystemClient {
 	}
 
 	public class Client {
-		public signal void connection_status(bool connected);
-
-		public bool connected { get { return connection.connected; } }
-
 		private Connection connection;
 
 		public Client(string cert_dir) throws Error {
-			connection = new Connection(cert_dir, (connected) => {
+			connection = new Connection(cert_dir);
-					connection_status(connected);
-				});
 		}
 
 		public async void ping() throws ClientError {

client/src/connection.vala

@@ -1,27 +1,17 @@
 namespace StudySystemClient {
 	public class Connection {
-		public delegate void StatusCallback(bool connected);
-
-		public bool connected { get; private set; }
-
-		private StatusCallback status_callback;
 		private SessionManager session_manager;
 		private TransactionManager transaction_manager;
 		private Worker worker;
 
-		public Connection(string cert_dir,
+		public Connection(string cert_dir) throws Error {
-						  owned StatusCallback status_callback)
-		throws Error {
 			var loopback = new InetAddress.loopback(SocketFamily.IPV6);
 			var session_factory
 				= new SessionFactory(loopback, 12888, cert_dir);
-			this.status_callback = (owned) status_callback;
 			session_manager = new SessionManager(
-				session_factory, (msg) => receive(msg),
+				session_factory, (msg) => receive(msg));
-				(connected) => update_status(connected));
 			transaction_manager = new TransactionManager();
 			worker = new Worker(session_manager);
-			connected = true;
 		}
 
 		public async Response.Body? send(Request.Body body) {
@@ -45,16 +35,6 @@ namespace StudySystemClient {
 					return false;
 				}, GLib.Priority.DEFAULT_IDLE);
 		}
-
-		private void update_status(bool connected) {
-			Idle.add(() => {
-					if (connected != this.connected) {
-						this.connected = connected;
-						status_callback(connected);
-					}
-					return false;
-				}, GLib.Priority.DEFAULT_IDLE);
-		}
 	}
 
 	private class Continuation {
@@ -104,19 +84,29 @@ namespace StudySystemClient {
 		}
 	}
 
-	private class Worker : Periodic {
+	private class Worker {
-		private const uint TASK_PERIOD_MS = 10;
+		private uint TASK_PERIOD_MS = 10;
 
 		private SessionManager session_manager;
+		private bool exit;
+		private Thread<void> thread;
 
 		public Worker(SessionManager session_manager) {
-			base(TASK_PERIOD_MS);
 			this.session_manager = session_manager;
-			start();
+			exit = false;
+			thread = new Thread<void>("connection_worker", body);
 		}
 
-		protected override void task() {
+		~Worker() {
+			exit = true;
+			thread.join();
+		}
+
+		private void body() {
+			while (!exit) {
 				session_manager.task();
+				Thread.usleep(1000 * TASK_PERIOD_MS);
+			}
 		}
 	}
 }

client/src/iterable_box.vala

@@ -1,52 +0,0 @@
-namespace StudySystemClient {
-	public class IterableBox<T> : Gtk.Box {
-		private List<T> elements;
-
-		public IterableBox(Gtk.Orientation orientation, int spacing) {
-			this.orientation = orientation;
-			this.spacing = spacing;
-			elements = new List<T>();
-		}
-
-		public new void append(T element) {
-			elements.append(element);
-			base.append(element as Gtk.Widget);
-		}
-
-		public new void remove(T element) {
-			elements.remove(element);
-			base.remove(element as Gtk.Widget);
-		}
-
-		public Iterator<Type, T> iterator() {
-			return new Iterator<Type, T>(elements);
-		}
-
-		public void sort(CompareDataFunc<T> comparison) {
-			elements.sort_with_data(comparison);
-			foreach (var element in elements)
-				reorder_child_after(element as Gtk.Widget, null);
-		}
-
-		public class Iterator<Type, T> {
-			private unowned List<T> head;
-			private unowned T value;
-
-			public Iterator(List<T> elements) {
-				head = elements;
-			}
-
-			public bool next() {
-				if (head.is_empty())
-					return false;
-				value = head.data;
-				head = head.next;
-				return true;
-			}
-
-			public unowned T get() {
-				return value;
-			}
-		}
-	}
-}

client/src/main_window.vala

@@ -12,38 +12,8 @@ namespace StudySystemClient {
 			header_bar.title_widget = title;
 			set_titlebar(header_bar);
 
-			var connection_indicator = new ConnectionIndicator(client);
 			var activities_view = new ActivitiesView(client);
-
+			set_child(activities_view);
-			var content = new Gtk.Box(Gtk.Orientation.VERTICAL, 0);
-			content.append(connection_indicator);
-			content.append(activities_view);
-
-			set_child(content);
-		}
-	}
-
-	private class ConnectionIndicator : Gtk.Box {
-		public ConnectionIndicator(Client client) {
-			var icon
-				= new Gtk.Image.from_icon_name("network-offline-symbolic");
-			var label = new Gtk.Label("Disconnected");
-
-			var content = new Gtk.Box(Gtk.Orientation.HORIZONTAL, 8);
-			content.margin_top = content.margin_bottom
-				= content.margin_start = content.margin_end = 12;
-			content.hexpand = true;
-			content.halign = Gtk.Align.CENTER;
-			content.append(icon);
-			content.append(label);
-
-			var revealer = new Gtk.Revealer();
-			revealer.set_child(content);
-			append(revealer);
-
-			client.connection_status.connect((connected) => {
-					revealer.reveal_child = !connected;
-				});
 		}
 	}
 }

client/src/meson.build

@@ -13,14 +13,10 @@ lib = library(
     'activities_view.vala',
     'activity.vala',
     'activity_card.vala',
-    'card.vala',
     'client.vala',
     'connection.vala',
     'der.vala',
-    'iterable_box.vala',
     'main_window.vala',
-    'periodic.vala',
-    'refresher.vala',
     'request.vala',
     'response.vala',
     'session_manager.vala',

client/src/periodic.vala

@@ -1,35 +0,0 @@
-namespace StudySystemClient {
-	public abstract class Periodic {
-		private uint period_ms;
-		private bool exit;
-		private Thread<void> thread;
-
-		protected Periodic(uint period_ms) {
-			this.period_ms = period_ms;
-			exit = true;
-		}
-
-		~Periodic() {
-			if (!exit) {
-				exit = true;
-				thread.join();
-			}
-		}
-
-		protected abstract void task();
-
-		public void start() {
-			if (exit) {
-				exit = false;
-				thread = new Thread<void>("Periodic task", body);
-			}
-		}
-
-		private void body() {
-			while (!exit) {
-				task();
-				Thread.usleep(1000 * period_ms);
-			}
-		}
-	}
-}

client/src/refresher.vala

@@ -1,23 +0,0 @@
-namespace StudySystemClient {
-	public interface IRefreshable {
-		public abstract async void refresh();
-	}
-
-	private class Refresher : Periodic {
-		private weak IRefreshable target;
-
-		public Refresher(IRefreshable target, uint period_ms) {
-			base(period_ms);
-			this.target = target;
-		}
-
-		protected override void task() {
-			if (target != null) {
-				Idle.add(() => {
-						target.refresh.begin();
-						return false;
-					});
-			}
-		}
-	}
-}

client/src/session_manager.vala

@@ -3,23 +3,19 @@ namespace StudySystemClient {
 		public delegate void ReceiveCallback(owned uint8[] msg);
 
 		private const uint INIT_RECONNECT_WAIT_MS = 500;
-		private const uint MAX_RECONNECT_WAIT_MS = 30000;
+		private const uint MAX_RECONNECT_WAIT_MS = 60000;
 		private const double RECONNECT_BACKOFF = 1.6;
 
 		private SessionFactory session_factory;
 		private ReceiveCallback receive_callback;
-		private Connection.StatusCallback status_callback;
 		private Session? session;
 		private AsyncQueue<OutgoingMessage> queue;
 		private uint reconnect_wait_ms;
 
-		public SessionManager(
+		public SessionManager(SessionFactory session_factory,
-			SessionFactory session_factory,
+							  owned ReceiveCallback receive_callback) {
-			owned ReceiveCallback receive_callback,
-			owned Connection.StatusCallback status_callback) {
 			this.session_factory = session_factory;
 			this.receive_callback = (owned) receive_callback;
-			this.status_callback = (owned) status_callback;
 			this.session = null;
 			queue = new AsyncQueue<OutgoingMessage>();
 			reconnect_wait_ms = INIT_RECONNECT_WAIT_MS;
@@ -44,7 +40,6 @@ namespace StudySystemClient {
 			if (msg.should_retry())
 				queue.push(msg);
 			session = null;
-			status_callback(false);
 		}
 
 		private void try_start_session() {
@@ -52,9 +47,7 @@ namespace StudySystemClient {
 				session = session_factory.start_session();
 				session.received.connect((msg) => receive_callback(msg));
 				reconnect_wait_ms = INIT_RECONNECT_WAIT_MS;
-				status_callback(true);
 			} catch (Error _) {
-				status_callback(false);
 				Thread.usleep(1000 * reconnect_wait_ms);
 				update_reconnect_wait();
 			}
@@ -72,7 +65,7 @@ namespace StudySystemClient {
 	public class SessionFactory {
 		private const string CA_FILENAME = "/ca.pem";
 		private const string CERT_FILENAME = "/client.pem";
-		private const uint TIMEOUT_S = 2;
+		private const uint TIMEOUT_S = 1;
 
 		private InetSocketAddress host;
 		private TlsCertificate cert;

client/styles.css

@@ -1,11 +1,11 @@
 .card-container {
-	background-color: color-mix(in oklab, @theme_base_color,
+	background-color: mix(@theme_base_color, @theme_bg_color, 0.7);
-								@theme_bg_color 60%);
 	padding: 6px;
 }
 
 .card {
-	box-shadow: 0 1px 2px rgba(0, 0, 0, 0.15);
+	border: 1px solid alpha(@theme_fg_color, 0.2);
+	box-shadow: 0 1px 2px alpha(black, 0.15);
 	background-color: @theme_bg_color;
 	padding: 12px 16px;
 }
@@ -15,7 +15,7 @@
 }
 
 .activity-priority {
-	color: color-mix(in oklab, @theme_fg_color 60%, @theme_bg_color);
+	color: alpha(@theme_fg_color, 0.6);
 }
 
 /*
@@ -27,3 +27,20 @@
 	margin-top: -2px;
 	margin-left: 3px;
 }
+
+/*
+ * Couldn't find a built-in way to get the common OSD overlay style of
+ * rounding the bottom corners but not the top ones, so doing this
+ * myself with this CSS rule.
+ */
+overlay > frame.osd {
+	border-radius: 0 0 8px 8px;
+}
+
+.popdown {
+	transition: transform 200ms ease-in-out;
+	transform: translateY(-100px);
+}
+.popdown.visible {
+	transform: translateY(0);
+}

server/src/session_server.erl

@@ -12,7 +12,6 @@ start_link(Socket) ->
 	gen_server:start_link(?MODULE, Socket, []).
 
 init(Socket) ->
-	ok = ssl:controlling_process(Socket, self()),
 	ok = ssl:setopts(Socket, [{active, true}]),
 	process_flag(trap_exit, true),
 	{ok, #{socket => Socket, transactions => #{}}}.
@@ -39,7 +38,9 @@ handle_info({'EXIT', Pid, Reason},
 	TransactionId = maps:get(Pid, Transactions),
 	Response = case Reason of
 				   {response, Value} -> Value;
-				   _ -> {error, serverError}
+				   _ ->
+					   io:format("Error handling request: ~p~n", [Reason]),
+					   {error, serverError}
 			   end,
 	send(Socket, TransactionId, Response),
 	{noreply, State#{transactions := maps:remove(Pid, Transactions)}};
@@ -58,24 +59,25 @@ code_change(_OldVsn, State, _Extra) ->
 
 handle_request(Request) ->
 	timer:kill_after(500),
-	exit({response, map_request(Request)}).
+	exit(map_request(Request)).
 
 map_request({ping, 'NULL'}) ->
-	{ack, 'NULL'};
+	{response, {ack, 'NULL'}};
 map_request({listActivities, 'NULL'}) ->
 	{activities, Activities} = subject_router:get_activities(),
-	{activities,
+	SortedActivities = lists:reverse(lists:keysort(3, Activities)),
+	{response, {activities,
 				[{'Activity', Subject, Type, round(Priority * 100)}
-	  || {Subject, Type, Priority} <- Activities]};
+				 || {Subject, Type, Priority} <- SortedActivities]}};
 map_request({logSession, {'Session', Subject, Type, Timestamp, Minutes}}) ->
 	Session = {unicode:characters_to_list(Subject),
 			   Type, Timestamp, Minutes},
 	case subject_router:log_session(Session) of
-		ok -> {ack, 'NULL'};
+		ok -> {response, {ack, 'NULL'}};
-		{error, _Error} -> {error, invalidArguments}
+		{error, _Error} -> {response, {error, invalidArguments}}
 	end;
 map_request(_) ->
-	{error, invalidArguments}.
+	{response, {error, invalidArguments}}.
 
 send(Socket, TransactionId, Response) ->
 	{ok, Encoded} = 'StudySystemProtocol':encode(

server/src/tcp_server.erl

@@ -41,7 +41,8 @@ handle_info(accept, State = #state{socket = Socket}) ->
 handle_info({handshake, TlsSocket}, State) ->
 	case ssl:handshake(TlsSocket, 5000) of
 		{ok, ClientSocket} ->
-			{ok, _Pid} = session_sup:start_session(ClientSocket);
+			{ok, Pid} = session_sup:start_session(ClientSocket),
+			ok = ssl:controlling_process(ClientSocket, Pid);
 		{error, _Reason} ->
 			ok
 	end,