feat: add visible flag for works

server-rs/crates/spacetime-module/src/big_fish/session.rs

@@ -23,6 +23,7 @@ pub fn big_fish_gallery_view(ctx: &AnonymousViewContext) -> Vec<BigFishWorkSumma
         .big_fish_creation_session()
         .by_big_fish_session_stage()
         .filter(BigFishCreationStage::Published)
+        .filter(|row| row.visible)
         .filter_map(|row| match build_big_fish_gallery_view_row(ctx, &row) {
             Ok(snapshot) => Some(snapshot),
             Err(error) => {
@@ -284,6 +285,7 @@ pub(crate) fn create_big_fish_session_tx(
             published_at: None,
             created_at,
             updated_at: created_at,
+            visible: true,
         });
     ctx.db.big_fish_agent_message().insert(BigFishAgentMessage {
         message_id: input.welcome_message_id,
@@ -492,6 +494,7 @@ pub(crate) fn submit_big_fish_message_tx(
         published_at: session.published_at,
         created_at: session.created_at,
         updated_at: submitted_at,
+        visible: session.visible,
     };
     replace_big_fish_session(ctx, &session, next_session);
 
@@ -542,6 +545,7 @@ pub(crate) fn finalize_big_fish_agent_message_turn_tx(
             published_at: session.published_at,
             created_at: session.created_at,
             updated_at,
+            visible: session.visible,
         };
         replace_big_fish_session(ctx, &session, next_session);
         return Err(error_message.to_string());
@@ -600,6 +604,7 @@ pub(crate) fn finalize_big_fish_agent_message_turn_tx(
         published_at: session.published_at,
         created_at: session.created_at,
         updated_at,
+        visible: session.visible,
     };
     replace_big_fish_session(ctx, &session, next_session);
 
@@ -667,6 +672,7 @@ pub(crate) fn compile_big_fish_draft_tx(
         published_at: session.published_at,
         created_at: session.created_at,
         updated_at: compiled_at,
+        visible: session.visible,
     };
     replace_big_fish_session(ctx, &session, next_session);
     for event in readiness.events {
@@ -768,6 +774,7 @@ pub(crate) fn record_big_fish_play_tx(
         published_at: session.published_at,
         created_at: session.created_at,
         updated_at: played_at,
+        visible: session.visible,
     };
     replace_big_fish_session(ctx, &session, next_session);
 
@@ -821,6 +828,7 @@ pub(crate) fn record_big_fish_like_tx(
             published_at: session.published_at,
             created_at: session.created_at,
             updated_at: liked_at,
+            visible: session.visible,
         };
         replace_big_fish_session(ctx, &session, next_session);
     }
@@ -888,6 +896,7 @@ fn remix_big_fish_work_tx(
         published_at: source.published_at,
         created_at: source.created_at,
         updated_at: remixed_at,
+        visible: source.visible,
     };
     replace_big_fish_session(ctx, &source, next_source);
 
@@ -909,6 +918,7 @@ fn remix_big_fish_work_tx(
         published_at: None,
         created_at: remixed_at,
         updated_at: remixed_at,
+        visible: true,
     };
     ctx.db.big_fish_creation_session().insert(target_session);
     ctx.db.big_fish_agent_message().insert(BigFishAgentMessage {
@@ -1238,6 +1248,7 @@ mod tests {
             },
             created_at: Timestamp::from_micros_since_unix_epoch(1),
             updated_at: Timestamp::from_micros_since_unix_epoch(1),
+            visible: true,
         }
     }