Add headless API

plugin/src/App/init.lua

@@ -16,6 +16,7 @@ local strict = require(Plugin.strict)
 local Dictionary = require(Plugin.Dictionary)
 local ServeSession = require(Plugin.ServeSession)
 local ApiContext = require(Plugin.ApiContext)
+local HeadlessAPI = require(Plugin.HeadlessAPI)
 local preloadAssets = require(Plugin.preloadAssets)
 local soundPlayer = require(Plugin.soundPlayer)
 local Theme = require(script.Theme)
@@ -48,6 +49,11 @@ function App:init()
 	self.host, self.setHost = Roact.createBinding(priorHost or "")
 	self.port, self.setPort = Roact.createBinding(priorPort or "")
 
+	self.headlessAPI, self.readOnlyHeadlessAPI = HeadlessAPI.new(self, Config, Settings)
+
+	-- selene: allow(global_usage)
+	_G.Rojo = self.readOnlyHeadlessAPI -- Expose headless to other plugins and command bar
+
 	self.patchInfo, self.setPatchInfo = Roact.createBinding({
 		changes = 0,
 		timestamp = os.time(),
@@ -78,6 +84,25 @@ function App:addNotification(text: string, timeout: number?)
 	})
 end
 
+function App:addThirdPartyNotification(source: string, text: string, timeout: number?)
+	if not Settings:get("showNotifications") then
+		return
+	end
+
+	local notifications = table.clone(self.state.notifications)
+	table.insert(notifications, {
+		text = text,
+		timestamp = DateTime.now().UnixTimestampMillis,
+		timeout = timeout or 3,
+		thirdParty = true,
+		source = source,
+	})
+
+	self:setState({
+		notifications = notifications,
+	})
+end
+
 function App:closeNotification(index: number)
 	local notifications = table.clone(self.state.notifications)
 	table.remove(notifications, index)
@@ -126,7 +151,7 @@ function App:setPriorEndpoint(host: string, port: string)
 	Settings:set("priorEndpoints", priorEndpoints)
 end
 
-function App:getHostAndPort()
+function App:getHostAndPort(): (string, string)
 	local host = self.host:getValue()
 	local port = self.port:getValue()
 
@@ -179,7 +204,7 @@ function App:releaseSyncLock()
 	Log.trace("Could not relase sync lock because it is owned by {}", lock.Value)
 end
 
-function App:startSession()
+function App:startSession(host: string?, port: string?)
 	local claimedLock, priorOwner = self:claimSyncLock()
 	if not claimedLock then
 		local msg = string.format("Could not sync because user '%s' is already syncing", tostring(priorOwner))
@@ -195,14 +220,16 @@ function App:startSession()
 		return
 	end
 
-	local host, port = self:getHostAndPort()
+	if host == nil or port == nil then
+		host, port = self:getHostAndPort()
+	end
 
 	local sessionOptions = {
 		openScriptsExternally = Settings:get("openScriptsExternally"),
 		twoWaySync = Settings:get("twoWaySync"),
 	}
 
-	local baseUrl = ("http://%s:%s"):format(host, port)
+	local baseUrl = string.format("http://%s:%s", host :: string, port :: string)
 	local apiContext = ApiContext.new(baseUrl)
 
 	local serveSession = ServeSession.new({
@@ -240,6 +267,8 @@ function App:startSession()
 	end)
 
 	serveSession:onStatusChanged(function(status, details)
+		self.headlessAPI.Connected = status == ServeSession.Status.Connected
+
 		if status == ServeSession.Status.Connecting then
 			self:setPriorEndpoint(host, port)
 
@@ -249,7 +278,7 @@ function App:startSession()
 			})
 			self:addNotification("Connecting to session...")
 		elseif status == ServeSession.Status.Connected then
-			local address = ("%s:%s"):format(host, port)
+			local address = string.format("%s:%s", host :: string, port :: string)
 			self:setState({
 				appStatus = AppStatus.Connected,
 				projectName = details,