kanban-service 0.7.0

Shared service layer implementing KanbanOperations over a pluggable PersistenceStore
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

use super::super::BackendFactory;
use crate::KanbanContext;
use kanban_core::AppConfig;
use kanban_domain::{ColumnUpdate, FieldUpdate, KanbanOperations};
use tempfile::TempDir;

pub async fn test_column_all_fields_roundtrip(factory: &BackendFactory) {
    let dir = TempDir::new().unwrap();
    let path = dir.path().join("test.store");
    let mut ctx = KanbanContext::open(factory(&path), AppConfig::default())
        .await
        .unwrap();

    let board = ctx.create_board("Board".into(), None).unwrap();
    let col = ctx.create_column(board.id, "Backlog".into(), None).unwrap();

    ctx.update_column(
        col.id,
        ColumnUpdate {
            name: Some("In Progress".into()),
            position: Some(3),
            wip_limit: FieldUpdate::Set(5),
        },
    )
    .unwrap();

    ctx.save().await.unwrap();
    let ctx = KanbanContext::open_deferred(factory(&path), AppConfig::default());

    let c = ctx.get_column(col.id).unwrap().unwrap();
    assert_eq!(c.name, "In Progress");
    assert_eq!(c.board_id, board.id);
    assert_eq!(c.position, 3);
    assert_eq!(c.wip_limit, Some(5));
    assert!(c.created_at <= c.updated_at);
}

pub async fn test_column_without_wip_limit_roundtrip(factory: &BackendFactory) {
    let dir = TempDir::new().unwrap();
    let path = dir.path().join("test.store");
    let mut ctx = KanbanContext::open(factory(&path), AppConfig::default())
        .await
        .unwrap();

    let board = ctx.create_board("Board".into(), None).unwrap();
    let col = ctx.create_column(board.id, "Open".into(), None).unwrap();

    ctx.save().await.unwrap();
    let ctx = KanbanContext::open_deferred(factory(&path), AppConfig::default());

    let c = ctx.get_column(col.id).unwrap().unwrap();
    assert_eq!(c.name, "Open");
    assert!(c.wip_limit.is_none());
}

pub async fn test_multiple_columns_preserve_positions(factory: &BackendFactory) {
    let dir = TempDir::new().unwrap();
    let path = dir.path().join("test.store");
    let mut ctx = KanbanContext::open(factory(&path), AppConfig::default())
        .await
        .unwrap();

    let board = ctx.create_board("Board".into(), None).unwrap();
    let col1 = ctx.create_column(board.id, "Todo".into(), Some(0)).unwrap();
    let col2 = ctx
        .create_column(board.id, "In Progress".into(), Some(1))
        .unwrap();
    let col3 = ctx.create_column(board.id, "Done".into(), Some(2)).unwrap();

    ctx.save().await.unwrap();
    let ctx = KanbanContext::open_deferred(factory(&path), AppConfig::default());

    let cols = ctx.list_columns(board.id).unwrap();
    assert_eq!(cols.len(), 3);
    assert_eq!(cols.iter().find(|c| c.id == col1.id).unwrap().position, 0);
    assert_eq!(cols.iter().find(|c| c.id == col2.id).unwrap().position, 1);
    assert_eq!(cols.iter().find(|c| c.id == col3.id).unwrap().position, 2);
}