Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
silky committed Jun 8, 2021
1 parent b6a0c4b commit d14e9fd
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 18 deletions.
20 changes: 10 additions & 10 deletions plutus-pab/app/Cli.hs
Expand Up @@ -95,7 +95,7 @@ import qualified Plutus.PAB.Db.Beam as Beam
import qualified Plutus.PAB.Db.Eventful as Eventful
import Plutus.PAB.Effects.Contract.ContractExe (ContractExe)
import qualified Plutus.PAB.Monitoring.Monitoring as LM
import Plutus.PAB.Types (Config (..), DbConfig (..), DbKind (..), chainIndexConfig,
import Plutus.PAB.Types (Config (..), DbConfig (..), chainIndexConfig,
metadataServerConfig, nodeServerConfig, walletServerConfig)
import qualified Plutus.PAB.Webserver.Server as PABServer
import Plutus.PAB.Webserver.Types (ContractActivationArgs (..))
Expand All @@ -108,7 +108,7 @@ runNoConfigCommand trace = \case

-- Run database migration
Migrate{dbPath} ->
let conf = DbConfig{dbConfigPoolSize=10, dbConfigFile=Text.pack dbPath, dbConfigDbKind=BeamDb} in
let conf = DbConfig{dbConfigPoolSize=10, dbConfigFile=Text.pack dbPath} in
App.beamMigrate (LM.convertLog LM.PABMsg trace) conf
-- TODO: Restore or delete
-- App.migrate (LM.convertLog LM.PABMsg trace) conf
Expand Down Expand Up @@ -194,19 +194,19 @@ runConfigCommand ConfigCommandArgs{ccaTrace, ccaPABConfig=Config {nodeServerConf

-- Install a contract
runConfigCommand ConfigCommandArgs{ccaTrace, ccaPABConfig=Config{dbConfig}} (InstallContract contractExe) =
case dbConfigDbKind dbConfig of
BeamDb ->
-- case dbConfigDbKind dbConfig of
-- BeamDb ->
do
connection <- App.beamDbConnect (LM.convertLog LM.PABMsg ccaTrace) dbConfig
fmap (either (error . show) id)
$ Beam.runBeamStoreAction connection
$ Contract.addDefinition @ContractExe contractExe
EventfulDb ->
do
connection <- Sqlite <$> App.dbConnect (LM.convertLog LM.PABMsg ccaTrace) dbConfig
fmap (either (error . show) id)
$ Eventful.runEventfulStoreAction connection (LM.convertLog (LM.PABMsg . LM.SLoggerBridge) ccaTrace)
$ Contract.addDefinition @ContractExe contractExe
-- EventfulDb ->
-- do
-- connection <- Sqlite <$> App.dbConnect (LM.convertLog LM.PABMsg ccaTrace) dbConfig
-- fmap (either (error . show) id)
-- $ Eventful.runEventfulStoreAction connection (LM.convertLog (LM.PABMsg . LM.SLoggerBridge) ccaTrace)
-- $ Contract.addDefinition @ContractExe contractExe

-- Get the state of a contract
runConfigCommand ConfigCommandArgs{ccaTrace, ccaPABConfig=Config{dbConfig}} (ContractState contractInstanceId) = do
Expand Down
1 change: 0 additions & 1 deletion plutus-pab/plutus-pab.yaml
@@ -1,7 +1,6 @@
dbConfig:
dbConfigFile: pab-core.db
dbConfigPoolSize: 20
dbConfigDbKind: BeamDb

pabWebserverConfig:
baseUrl: http://localhost:9080
Expand Down
7 changes: 0 additions & 7 deletions plutus-pab/src/Plutus/PAB/Types.hs
Expand Up @@ -81,17 +81,10 @@ data DbConfig =
-- ^ The path to the sqlite database file. May be absolute or relative.
, dbConfigPoolSize :: Int
-- ^ Max number of concurrent sqlite database connections.
, dbConfigDbKind :: DbKind
-- ^ The particular kind of database we're using; see 'DbKind'.
}
deriving (Show, Eq, Generic)
deriving anyclass (ToJSON, FromJSON)

data DbKind
= BeamDb
| EventfulDb
deriving (Generic, Show, Eq, FromJSON, ToJSON)

data Config =
Config
{ dbConfig :: DbConfig
Expand Down

0 comments on commit d14e9fd

Please sign in to comment.