1
#![allow(clippy::unwrap_used)]
2
#![allow(clippy::expect_used)]
3
use std::sync::{Arc, RwLock};
4
use ustr::Ustr;
5

            
6
use serde_json::Map as JsonMap;
7
use serde_json::Value;
8
use serde_json::Value as JsonValue;
9

            
10
use crate::ast::Moo;
11
use crate::ast::abstract_comprehension::AbstractComprehensionBuilder;
12
use crate::ast::ac_operators::ACOperatorKind;
13
use crate::ast::comprehension::ComprehensionBuilder;
14
use crate::ast::records::RecordValue;
15
use crate::ast::{
16
    AbstractLiteral, Atom, DeclarationPtr, Domain, Expression, FuncAttr, IntVal, JectivityAttr,
17
    Literal, MSetAttr, Name, PartialityAttr, Range, RecordEntry, SetAttr, SymbolTable,
18
    SymbolTablePtr,
19
};
20
use crate::ast::{DomainPtr, Metadata};
21
use crate::context::Context;
22
use crate::error::{Error, Result};
23
use crate::{Model, bug, error, into_matrix_expr, throw_error};
24

            
25
#[allow(unused_macros)]
26
macro_rules! parser_trace {
27
    ($($arg:tt)+) => {
28
        log::trace!(target:"jsonparser",$($arg)+)
29
    };
30
}
31

            
32
#[allow(unused_macros)]
33
macro_rules! parser_debug {
34
    ($($arg:tt)+) => {
35
        log::debug!(target:"jsonparser",$($arg)+)
36
    };
37
}
38

            
39
9767
pub fn model_from_json(str: &str, context: Arc<RwLock<Context<'static>>>) -> Result<Model> {
40
9767
    let mut m = Model::new(context);
41
9767
    let v: JsonValue = serde_json::from_str(str)?;
42
9767
    let statements = v["mStatements"]
43
9767
        .as_array()
44
9767
        .ok_or(error!("mStatements is not an array"))?;
45

            
46
28732
    for statement in statements {
47
28732
        let entry = statement
48
28732
            .as_object()
49
28732
            .ok_or(error!("mStatements contains a non-object"))?
50
28732
            .iter()
51
28732
            .next()
52
28732
            .ok_or(error!("mStatements contains an empty object"))?;
53

            
54
28732
        match entry.0.as_str() {
55
28732
            "Declaration" => {
56
20015
                let decl = entry
57
20015
                    .1
58
20015
                    .as_object()
59
20015
                    .ok_or(error!("Declaration is not an object".to_owned()))?;
60

            
61
                // One field in the declaration should tell us what kind it is.
62
                //
63
                // Find it, ignoring the other fields.
64
                //
65
                // e.g. FindOrGiven,
66

            
67
20015
                let mut valid_decl: bool = false;
68
20015
                let scope = m.symbols_ptr_unchecked().clone();
69
20015
                let model = &mut m;
70
20015
                for (kind, value) in decl {
71
20015
                    match kind.as_str() {
72
20015
                        "FindOrGiven" => {
73
18062
                            parse_variable(value, &mut model.symbols_mut())?;
74
18062
                            valid_decl = true;
75
18062
                            break;
76
                        }
77
1953
                        "Letting" => {
78
1953
                            parse_letting(value, &scope)?;
79
1932
                            valid_decl = true;
80
1932
                            break;
81
                        }
82
                        _ => continue,
83
                    }
84
                }
85

            
86
19994
                if !valid_decl {
87
                    throw_error!("Declaration is not a valid kind")?;
88
19994
                }
89
            }
90
8717
            "SuchThat" => {
91
8717
                let constraints_arr = match entry.1.as_array() {
92
8717
                    Some(x) => x,
93
                    None => bug!("SuchThat is not a vector"),
94
                };
95

            
96
8717
                let constraints: Vec<Expression> = constraints_arr
97
8717
                    .iter()
98
13316
                    .map(|x| parse_expression(x, m.symbols_ptr_unchecked()))
99
8717
                    .collect::<Result<Vec<_>>>()?;
100
8717
                m.add_constraints(constraints);
101
            }
102
            otherwise => bug!("Unhandled Statement {:#?}", otherwise),
103
        }
104
    }
105
9746
    Ok(m)
106
9767
}
107

            
108
18062
fn parse_variable(v: &JsonValue, symtab: &mut SymbolTable) -> Result<()> {
109
18062
    let arr = v.as_array().ok_or(error!("FindOrGiven is not an array"))?;
110
18062
    let name = arr[1]
111
18062
        .as_object()
112
18062
        .ok_or(error!("FindOrGiven[1] is not an object"))?["Name"]
113
18062
        .as_str()
114
18062
        .ok_or(error!("FindOrGiven[1].Name is not a string"))?;
115

            
116
18062
    let name = Name::User(Ustr::from(name));
117

            
118
18062
    let domain = arr[2]
119
18062
        .as_object()
120
18062
        .ok_or(error!("FindOrGiven[2] is not an object"))?
121
18062
        .iter()
122
18062
        .next()
123
18062
        .ok_or(error!("FindOrGiven[2] is an empty object"))?;
124

            
125
18062
    let domain = parse_domain(domain.0, domain.1, symtab)?;
126

            
127
18062
    symtab
128
18062
        .insert(DeclarationPtr::new_find(name.clone(), domain))
129
18062
        .ok_or(Error::Parse(format!(
130
18062
            "Could not add {name} to symbol table as it already exists"
131
18062
        )))
132
18062
}
133

            
134
1953
fn parse_letting(v: &JsonValue, scope: &SymbolTablePtr) -> Result<()> {
135
1953
    let arr = v.as_array().ok_or(error!("Letting is not an array"))?;
136
1953
    let name = arr[0]
137
1953
        .as_object()
138
1953
        .ok_or(error!("Letting[0] is not an object"))?["Name"]
139
1953
        .as_str()
140
1953
        .ok_or(error!("Letting[0].Name is not a string"))?;
141
1953
    let name = Name::User(Ustr::from(name));
142
    // value letting
143
1953
    if let Ok(value) = parse_expression(&arr[1], scope) {
144
1617
        let mut symtab = scope.write();
145
1617
        symtab
146
1617
            .insert(DeclarationPtr::new_value_letting(name.clone(), value))
147
1617
            .ok_or(Error::Parse(format!(
148
1617
                "Could not add {name} to symbol table as it already exists"
149
1617
            )))
150
    } else {
151
        // domain letting
152
336
        let domain = &arr[1]
153
336
            .as_object()
154
336
            .ok_or(error!("Letting[1] is not an object".to_owned()))?["Domain"]
155
336
            .as_object()
156
336
            .ok_or(error!("Letting[1].Domain is not an object"))?
157
336
            .iter()
158
336
            .next()
159
336
            .ok_or(error!("Letting[1].Domain is an empty object"))?;
160

            
161
336
        let mut symtab = scope.write();
162
336
        let domain = parse_domain(domain.0, domain.1, &mut symtab)?;
163

            
164
336
        symtab
165
336
            .insert(DeclarationPtr::new_domain_letting(name.clone(), domain))
166
336
            .ok_or(Error::Parse(format!(
167
336
                "Could not add {name} to symbol table as it already exists"
168
336
            )))
169
    }
170
1953
}
171

            
172
34652
fn parse_domain(
173
34652
    domain_name: &str,
174
34652
    domain_value: &JsonValue,
175
34652
    symbols: &mut SymbolTable,
176
34652
) -> Result<DomainPtr> {
177
34652
    match domain_name {
178
34652
        "DomainInt" => Ok(parse_int_domain(domain_value, symbols)?),
179
8925
        "DomainBool" => Ok(Domain::bool()),
180
4284
        "DomainReference" => {
181
672
            let name = Name::user(
182
672
                domain_value
183
672
                    .as_array()
184
672
                    .ok_or(error!("DomainReference is not an array"))?[0]
185
672
                    .as_object()
186
672
                    .ok_or(error!("DomainReference[0] is not an object"))?["Name"]
187
672
                    .as_str()
188
672
                    .ok_or(error!("DomainReference[0].Name is not a string"))?,
189
            );
190
672
            let ptr = symbols
191
672
                .lookup(&name)
192
672
                .ok_or(error!(format!("Name {name} not found")))?;
193
672
            let dom =
194
672
                Domain::reference(ptr).ok_or(error!("Could not construct reference domain"))?;
195
672
            Ok(dom)
196
        }
197
3612
        "DomainSet" => {
198
231
            let dom = domain_value.get(2).and_then(|v| v.as_object());
199
231
            let domain_obj = dom.ok_or(error!("DomainSet is missing domain object"))?;
200
231
            let domain = domain_obj
201
231
                .iter()
202
231
                .next()
203
231
                .ok_or(Error::Parse("DomainSet is an empty object".to_owned()))?;
204
231
            let domain = parse_domain(domain.0.as_str(), domain.1, symbols)?;
205
231
            let size = domain_value
206
231
                .get(1)
207
231
                .and_then(|v| v.as_object())
208
231
                .ok_or(error!("Set size attributes is not an object"))?;
209
231
            let size = parse_size_attr(size, symbols)?;
210
231
            let attr: SetAttr<IntVal> = SetAttr { size };
211
231
            Ok(Domain::set(attr, domain))
212
        }
213
3381
        "DomainMSet" => {
214
378
            let dom = domain_value
215
378
                .get(2)
216
378
                .and_then(|v| v.as_object())
217
378
                .expect("domain object exists");
218
378
            let domain = dom
219
378
                .iter()
220
378
                .next()
221
378
                .ok_or(Error::Parse("DomainMSet is an empty object".to_owned()))?;
222
378
            let domain = parse_domain(domain.0.as_str(), domain.1, symbols)?;
223

            
224
            // Parse Attributes
225
378
            let attributes = domain_value
226
378
                .get(1)
227
378
                .and_then(|v| v.as_array())
228
378
                .ok_or(error!("MSet attributes is not a json array"))?;
229

            
230
378
            let size = attributes
231
378
                .first()
232
378
                .and_then(|v| v.as_object())
233
378
                .ok_or(error!("MSet size attributes is not an object"))?;
234
378
            let size = parse_size_attr(size, symbols)?;
235

            
236
378
            let occurrence = attributes
237
378
                .get(1)
238
378
                .and_then(|v| v.as_object())
239
378
                .ok_or(error!("MSet occurrence attributes is not an object"))?;
240
378
            let occurrence = parse_occur_attr(occurrence, symbols)?;
241

            
242
378
            let attr: MSetAttr<IntVal> = MSetAttr { size, occurrence };
243
378
            Ok(Domain::mset(attr, domain))
244
        }
245

            
246
3003
        "DomainMatrix" => {
247
2289
            let domain_value = domain_value
248
2289
                .as_array()
249
2289
                .ok_or(error!("Domain matrix is not an array"))?;
250

            
251
2289
            let indexed_by_domain = domain_value[0].clone();
252
2289
            let (index_domain_name, index_domain_value) = indexed_by_domain
253
2289
                .as_object()
254
2289
                .ok_or(error!("DomainMatrix[0] is not an object"))?
255
2289
                .iter()
256
2289
                .next()
257
2289
                .ok_or(error!(""))?;
258

            
259
2289
            let (value_domain_name, value_domain_value) = domain_value[1]
260
2289
                .as_object()
261
2289
                .ok_or(error!(""))?
262
2289
                .iter()
263
2289
                .next()
264
2289
                .ok_or(error!(""))?;
265

            
266
            // Conjure stores a 2-d matrix as a matrix of a matrix.
267
            //
268
            // Therefore, the index is always a Domain.
269

            
270
2289
            let mut index_domains: Vec<DomainPtr> = vec![];
271

            
272
2289
            index_domains.push(parse_domain(
273
2289
                index_domain_name,
274
2289
                index_domain_value,
275
2289
                symbols,
276
            )?);
277

            
278
            // We want to store 2-d matrices as a matrix with two index domains, not a matrix in a
279
            // matrix.
280
            //
281
            // Walk through the value domain until it is not a DomainMatrix, adding the index to
282
            // our list of indices.
283
2289
            let mut value_domain = parse_domain(value_domain_name, value_domain_value, symbols)?;
284
2667
            while let Some((new_value_domain, mut indices)) = value_domain.as_matrix() {
285
378
                index_domains.append(&mut indices);
286
378
                value_domain = new_value_domain.clone()
287
            }
288

            
289
2289
            Ok(Domain::matrix(value_domain, index_domains))
290
        }
291
714
        "DomainTuple" => {
292
147
            let domain_value = domain_value
293
147
                .as_array()
294
147
                .ok_or(error!("Domain tuple is not an array"))?;
295

            
296
            //iterate through the array and parse each domain
297
147
            let domain = domain_value
298
147
                .iter()
299
294
                .map(|x| {
300
294
                    let domain = x
301
294
                        .as_object()
302
294
                        .ok_or(error!("DomainTuple[0] is not an object"))?
303
294
                        .iter()
304
294
                        .next()
305
294
                        .ok_or(error!("DomainTuple[0] is an empty object"))?;
306
294
                    parse_domain(domain.0, domain.1, symbols)
307
294
                })
308
147
                .collect::<Result<Vec<DomainPtr>>>()?;
309

            
310
147
            Ok(Domain::tuple(domain))
311
        }
312
567
        "DomainRecord" => {
313
21
            let domain_value = domain_value
314
21
                .as_array()
315
21
                .ok_or(error!("Domain Record is not a json array"))?;
316

            
317
21
            let mut record_entries = vec![];
318

            
319
42
            for item in domain_value {
320
                //collect the name of the record field
321
42
                let name = item[0]
322
42
                    .as_object()
323
42
                    .ok_or(error!("FindOrGiven[1] is not an object"))?["Name"]
324
42
                    .as_str()
325
42
                    .ok_or(error!("FindOrGiven[1].Name is not a string"))?;
326

            
327
42
                let name = Name::User(Ustr::from(name));
328
                // then collect the domain of the record field
329
42
                let domain = item[1]
330
42
                    .as_object()
331
42
                    .ok_or(error!("FindOrGiven[2] is not an object"))?
332
42
                    .iter()
333
42
                    .next()
334
42
                    .ok_or(error!("FindOrGiven[2] is an empty object"))?;
335

            
336
42
                let domain = parse_domain(domain.0, domain.1, symbols)?;
337

            
338
42
                let rec = RecordEntry { name, domain };
339

            
340
42
                record_entries.push(rec);
341
            }
342

            
343
            // add record fields to symbol table
344
42
            for decl in record_entries
345
21
                .iter()
346
21
                .cloned()
347
21
                .map(DeclarationPtr::new_record_field)
348
            {
349
42
                symbols.insert(decl).ok_or(error!(
350
                    "record field should not already be in the symbol table"
351
                ))?;
352
            }
353

            
354
21
            Ok(Domain::record(record_entries))
355
        }
356
546
        "DomainFunction" => {
357
546
            let domain = domain_value
358
546
                .get(2)
359
546
                .and_then(|v| v.as_object())
360
546
                .ok_or(error!("Function domain is not an object"))?;
361
546
            let domain = domain
362
546
                .iter()
363
546
                .next()
364
546
                .ok_or(Error::Parse("DomainSet is an empty object".to_owned()))?;
365
546
            let domain = parse_domain(domain.0.as_str(), domain.1, symbols)?;
366

            
367
546
            let codomain = domain_value
368
546
                .get(3)
369
546
                .and_then(|v| v.as_object())
370
546
                .ok_or(error!("Function codomain is not an object"))?;
371
546
            let codomain = codomain
372
546
                .iter()
373
546
                .next()
374
546
                .ok_or(Error::Parse("DomainSet is an empty object".to_owned()))?;
375
546
            let codomain = parse_domain(codomain.0.as_str(), codomain.1, symbols)?;
376

            
377
            // Attribute parsing
378
546
            let attributes = domain_value
379
546
                .get(1)
380
546
                .and_then(|v| v.as_array())
381
546
                .ok_or(error!("Function attributes is not a json array"))?;
382
546
            let size = attributes
383
546
                .first()
384
546
                .and_then(|v| v.as_object())
385
546
                .ok_or(error!("Function size attributes is not an object"))?;
386
546
            let size = parse_size_attr(size, symbols)?;
387
546
            let partiality = attributes
388
546
                .get(1)
389
546
                .and_then(|v| v.as_str())
390
546
                .ok_or(error!("Function partiality is not a string"))?;
391
546
            let partiality = match partiality {
392
546
                "PartialityAttr_Partial" => Some(PartialityAttr::Partial),
393
84
                "PartialityAttr_Total" => Some(PartialityAttr::Total),
394
                _ => None,
395
            };
396
546
            let partiality =
397
546
                partiality.ok_or(Error::Parse("Partiality is an unknown type".to_owned()))?;
398
546
            let jectivity = attributes
399
546
                .get(2)
400
546
                .and_then(|v| v.as_str())
401
546
                .ok_or(error!("Function jectivity is not a string"))?;
402
546
            let jectivity = match jectivity {
403
546
                "JectivityAttr_Injective" => Some(JectivityAttr::Injective),
404
462
                "JectivityAttr_Surjective" => Some(JectivityAttr::Surjective),
405
420
                "JectivityAttr_Bijective" => Some(JectivityAttr::Bijective),
406
378
                "JectivityAttr_None" => Some(JectivityAttr::None),
407
                _ => None,
408
            };
409
546
            let jectivity =
410
546
                jectivity.ok_or(Error::Parse("Jectivity is an unknown type".to_owned()))?;
411

            
412
546
            let attr: FuncAttr<IntVal> = FuncAttr {
413
546
                size,
414
546
                partiality,
415
546
                jectivity,
416
546
            };
417

            
418
546
            Ok(Domain::function(attr, domain, codomain))
419
        }
420
        _ => Err(Error::Parse(
421
            "FindOrGiven[2] is an unknown object".to_owned(), // consider covered
422
        )),
423
    }
424
34652
}
425

            
426
1155
fn parse_size_attr(
427
1155
    attr_map: &JsonMap<String, JsonValue>,
428
1155
    symbols: &mut SymbolTable,
429
1155
) -> Result<Range<IntVal>> {
430
1155
    let scope = SymbolTablePtr::new();
431
1155
    *scope.write() = symbols.clone();
432

            
433
1155
    let attr_obj = attr_map
434
1155
        .iter()
435
1155
        .next()
436
1155
        .ok_or(Error::Parse("SizeAttr is an empty object".to_owned()))?;
437
1155
    match attr_obj.0.as_str() {
438
1155
        "SizeAttr_None" => Ok(Range::Unbounded),
439
567
        "SizeAttr_MinSize" => {
440
273
            let size = parse_expression_to_int_val(attr_obj.1, &scope)?;
441
273
            Ok(Range::UnboundedR(size))
442
        }
443
294
        "SizeAttr_MaxSize" => {
444
84
            let size = parse_expression_to_int_val(attr_obj.1, &scope)?;
445
84
            Ok(Range::UnboundedL(size))
446
        }
447
210
        "SizeAttr_MinMaxSize" => {
448
84
            let min_max = attr_obj
449
84
                .1
450
84
                .as_array()
451
84
                .ok_or(error!("SizeAttr MinMaxSize is not a json array"))?;
452
84
            let min = min_max
453
84
                .first()
454
84
                .ok_or(error!("SizeAttr Min is not present"))?;
455
84
            let min_int = parse_expression_to_int_val(min, &scope)?;
456
84
            let max = min_max
457
84
                .get(1)
458
84
                .ok_or(error!("SizeAttr Max is not present"))?;
459
84
            let max_int = parse_expression_to_int_val(max, &scope)?;
460
84
            Ok(Range::Bounded(min_int, max_int))
461
        }
462
126
        "SizeAttr_Size" => {
463
126
            let size = parse_expression_to_int_val(attr_obj.1, &scope)?;
464
126
            Ok(Range::Single(size))
465
        }
466
        _ => Err(Error::Parse("SizeAttr is an unknown type".to_owned())),
467
    }
468
1155
}
469

            
470
378
fn parse_occur_attr(
471
378
    attr_map: &JsonMap<String, JsonValue>,
472
378
    symbols: &mut SymbolTable,
473
378
) -> Result<Range<IntVal>> {
474
378
    let scope = SymbolTablePtr::new();
475
378
    *scope.write() = symbols.clone();
476
378
    let attr_obj = attr_map
477
378
        .iter()
478
378
        .next()
479
378
        .ok_or(Error::Parse("OccurAttr is an empty object".to_owned()))?;
480
378
    match attr_obj.0.as_str() {
481
378
        "OccurAttr_None" => Ok(Range::Unbounded),
482
210
        "OccurAttr_MinOccur" => {
483
42
            let size_int = parse_expression_to_int_val(attr_obj.1, &scope)?;
484
42
            Ok(Range::UnboundedR(size_int))
485
        }
486
168
        "OccurAttr_MaxOccur" => {
487
84
            let size_int = parse_expression_to_int_val(attr_obj.1, &scope)?;
488
84
            Ok(Range::UnboundedL(size_int))
489
        }
490
84
        "OccurAttr_MinMaxOccur" => {
491
84
            let min_max = attr_obj
492
84
                .1
493
84
                .as_array()
494
84
                .ok_or(error!("OccurAttr MinMaxOccur is not a json array"))?;
495
84
            let min = min_max
496
84
                .first()
497
84
                .ok_or(error!("OccurAttr Min is not present"))?;
498
84
            let min_int = parse_expression_to_int_val(min, &scope)?;
499
84
            let max = min_max
500
84
                .get(1)
501
84
                .ok_or(error!("OccurAttr Max is not present"))?;
502
84
            let max_int = parse_expression_to_int_val(max, &scope)?;
503
84
            Ok(Range::Bounded(min_int, max_int))
504
        }
505
        "OccurAttr_Size" => {
506
            let size_int = parse_expression_to_int_val(attr_obj.1, &scope)?;
507
            Ok(Range::Single(size_int))
508
        }
509
        _ => Err(Error::Parse("OccurAttr is an unknown type".to_owned())),
510
    }
511
378
}
512

            
513
25727
fn parse_int_domain(v: &JsonValue, symbols: &SymbolTable) -> Result<DomainPtr> {
514
25727
    let scope = SymbolTablePtr::new();
515
25727
    *scope.write() = symbols.clone();
516

            
517
25727
    let mut ranges = Vec::new();
518
25727
    let arr = v
519
25727
        .as_array()
520
25727
        .ok_or(error!("DomainInt is not an array".to_owned()))?[1]
521
25727
        .as_array()
522
25727
        .ok_or(error!("DomainInt[1] is not an array".to_owned()))?;
523
26882
    for range in arr {
524
26882
        let range = range
525
26882
            .as_object()
526
26882
            .ok_or(error!("DomainInt[1] contains a non-object"))?
527
26882
            .iter()
528
26882
            .next()
529
26882
            .ok_or(error!("DomainInt[1] contains an empty object"))?;
530
26882
        match range.0.as_str() {
531
26882
            "RangeBounded" => {
532
25013
                let arr = range
533
25013
                    .1
534
25013
                    .as_array()
535
25013
                    .ok_or(error!("RangeBounded is not an array".to_owned()))?;
536
25013
                let mut nums = Vec::new();
537
50026
                for item in arr.iter() {
538
50026
                    let num = parse_expression_to_int_val(item, &scope)?;
539
50026
                    nums.push(num);
540
                }
541
25013
                let lower = nums
542
25013
                    .first()
543
25013
                    .cloned()
544
25013
                    .ok_or(error!("RangeBounded lower bound missing"))?;
545
25013
                let upper = nums
546
25013
                    .get(1)
547
25013
                    .cloned()
548
25013
                    .ok_or(error!("RangeBounded upper bound missing"))?;
549
25013
                ranges.push(Range::Bounded(lower, upper));
550
            }
551
1869
            "RangeSingle" => {
552
1869
                let num = parse_expression_to_int_val(range.1, &scope)?;
553
1869
                ranges.push(Range::Single(num));
554
            }
555
            _ => return throw_error!("DomainInt[1] contains an unknown object"),
556
        }
557
    }
558
25727
    Ok(Domain::int(ranges))
559
25727
}
560

            
561
52840
fn parse_expression_to_int_val(obj: &JsonValue, scope: &SymbolTablePtr) -> Result<IntVal> {
562
52840
    parser_trace!("trying to parse domain value as expression: {}", obj);
563
52840
    let expr = parse_expression(obj, scope)?;
564

            
565
52840
    if let Some(Literal::Int(i)) = expr.clone().into_literal() {
566
51307
        return Ok(IntVal::Const(i));
567
1533
    }
568

            
569
945
    if let Expression::Atomic(_, Atom::Reference(reference)) = &expr
570
945
        && let Some(reference_val) = IntVal::new_ref(reference)
571
    {
572
945
        return Ok(reference_val);
573
588
    }
574

            
575
588
    IntVal::new_expr(Moo::new(expr)).ok_or(error!("Could not parse integer expression"))
576
52840
}
577

            
578
type BinOp = fn(Metadata, Moo<Expression>, Moo<Expression>) -> Expression;
579
type UnaryOp = fn(Metadata, Moo<Expression>) -> Expression;
580

            
581
48283
fn binary_operator(op_name: &str) -> Option<BinOp> {
582
48283
    match op_name {
583
48283
        "MkOpIn" => Some(Expression::In),
584
47905
        "MkOpUnion" => Some(Expression::Union),
585
47779
        "MkOpIntersect" => Some(Expression::Intersect),
586
47653
        "MkOpSupset" => Some(Expression::Supset),
587
47485
        "MkOpSupsetEq" => Some(Expression::SupsetEq),
588
47317
        "MkOpSubset" => Some(Expression::Subset),
589
47107
        "MkOpSubsetEq" => Some(Expression::SubsetEq),
590
46939
        "MkOpEq" => Some(Expression::Eq),
591
34003
        "MkOpNeq" => Some(Expression::Neq),
592
31525
        "MkOpGeq" => Some(Expression::Geq),
593
30097
        "MkOpLeq" => Some(Expression::Leq),
594
26989
        "MkOpGt" => Some(Expression::Gt),
595
25813
        "MkOpLt" => Some(Expression::Lt),
596
23751
        "MkOpLexLt" => Some(Expression::LexLt),
597
23415
        "MkOpLexGt" => Some(Expression::LexGt),
598
23415
        "MkOpLexLeq" => Some(Expression::LexLeq),
599
22911
        "MkOpLexGeq" => Some(Expression::LexGeq),
600
22911
        "MkOpDiv" => Some(Expression::UnsafeDiv),
601
21189
        "MkOpMod" => Some(Expression::UnsafeMod),
602
20139
        "MkOpMinus" => Some(Expression::Minus),
603
18417
        "MkOpImply" => Some(Expression::Imply),
604
16527
        "MkOpIff" => Some(Expression::Iff),
605
16317
        "MkOpPow" => Some(Expression::UnsafePow),
606
15015
        "MkOpImage" => Some(Expression::Image),
607
14931
        "MkOpImageSet" => Some(Expression::ImageSet),
608
14847
        "MkOpPreImage" => Some(Expression::PreImage),
609
14763
        "MkOpInverse" => Some(Expression::Inverse),
610
14679
        "MkOpRestrict" => Some(Expression::Restrict),
611
14595
        _ => None,
612
    }
613
48283
}
614

            
615
29190
fn unary_operator(op_name: &str) -> Option<UnaryOp> {
616
29190
    match op_name {
617
29190
        "MkOpNot" => Some(Expression::Not),
618
27216
        "MkOpNegate" => Some(Expression::Neg),
619
19530
        "MkOpTwoBars" => Some(Expression::Abs),
620
18900
        "MkOpAnd" => Some(Expression::And),
621
14784
        "MkOpSum" => Some(Expression::Sum),
622
8988
        "MkOpProduct" => Some(Expression::Product),
623
7476
        "MkOpOr" => Some(Expression::Or),
624
4578
        "MkOpMin" => Some(Expression::Min),
625
3486
        "MkOpMax" => Some(Expression::Max),
626
2436
        "MkOpAllDiff" => Some(Expression::AllDiff),
627
336
        "MkOpToInt" => Some(Expression::ToInt),
628
168
        "MkOpDefined" => Some(Expression::Defined),
629
84
        "MkOpRange" => Some(Expression::Range),
630
        _ => None,
631
    }
632
29190
}
633

            
634
148354
pub fn parse_expression(obj: &JsonValue, scope: &SymbolTablePtr) -> Result<Expression> {
635
148354
    let fail = |stage: &str| -> Error {
636
546
        Error::Parse(format!(
637
546
            "Could not parse expression at stage `{stage}` for json `{obj}`"
638
546
        ))
639
546
    };
640

            
641
378
    match obj {
642
148144
        Value::Object(op) if op.contains_key("Op") => {
643
37802
            let op_obj = op
644
37802
                .get("Op")
645
37802
                .and_then(Value::as_object)
646
37802
                .ok_or_else(|| fail("Op.as_object"))?;
647
37802
            let (op_name, _) = op_obj.iter().next().ok_or_else(|| fail("Op.iter().next"))?;
648

            
649
37802
            if op_obj.contains_key("MkOpFlatten") {
650
210
                parse_flatten_op(op_obj, scope)
651
37592
            } else if op_obj.contains_key("MkOpTable") {
652
63
                parse_table_op(op_obj, scope)
653
37529
            } else if op_obj.contains_key("MkOpIndexing") || op_obj.contains_key("MkOpSlicing") {
654
6090
                parse_indexing_slicing_op(op_obj, scope)
655
31439
            } else if binary_operator(op_name).is_some() {
656
16844
                parse_bin_op(op_obj, scope)
657
14595
            } else if unary_operator(op_name).is_some() {
658
14595
                parse_unary_op(op_obj, scope)
659
            } else {
660
                Err(fail("Op.unknown"))
661
            }
662
        }
663
110342
        Value::Object(comprehension) if comprehension.contains_key("Comprehension") => {
664
            parse_comprehension(comprehension, scope.clone(), None)
665
        }
666
110342
        Value::Object(refe) if refe.contains_key("Reference") => {
667
30473
            let ref_arr = refe["Reference"]
668
30473
                .as_array()
669
30473
                .ok_or_else(|| fail("Reference.as_array"))?;
670
30473
            let ref_obj = ref_arr
671
30473
                .first()
672
30473
                .and_then(|x| x.as_object())
673
30473
                .ok_or_else(|| fail("Reference[0].as_object"))?;
674
30473
            let name = ref_obj
675
30473
                .get("Name")
676
30473
                .and_then(|x| x.as_str())
677
30473
                .ok_or_else(|| fail("Reference[0].Name.as_str"))?;
678
30473
            let user_name = Name::User(Ustr::from(name));
679

            
680
30473
            let declaration: DeclarationPtr = scope
681
30473
                .read()
682
30473
                .lookup(&user_name)
683
30473
                .ok_or_else(|| fail("Reference.lookup"))?;
684

            
685
30473
            Ok(Expression::Atomic(
686
30473
                Metadata::new(),
687
30473
                Atom::Reference(crate::ast::Reference::new(declaration)),
688
30473
            ))
689
        }
690
79869
        Value::Object(abslit) if abslit.contains_key("AbstractLiteral") => {
691
6468
            let abstract_literal = abslit["AbstractLiteral"]
692
6468
                .as_object()
693
6468
                .ok_or_else(|| fail("AbstractLiteral.as_object"))?;
694

            
695
6468
            if abstract_literal.contains_key("AbsLitSet") {
696
42
                parse_abs_lit(&abslit["AbstractLiteral"]["AbsLitSet"], scope)
697
6426
            } else if abstract_literal.contains_key("AbsLitFunction") {
698
42
                parse_abs_function(&abslit["AbstractLiteral"]["AbsLitFunction"], scope)
699
6384
            } else if abstract_literal.contains_key("AbsLitMSet") {
700
                parse_abs_mset(&abslit["AbstractLiteral"]["AbsLitMSet"], scope)
701
            } else {
702
6384
                parse_abstract_matrix_as_expr(obj, scope)
703
            }
704
        }
705

            
706
73401
        Value::Object(constant) if constant.contains_key("Constant") => {
707
65274
            parse_constant(constant, scope).or_else(|_| parse_abstract_matrix_as_expr(obj, scope))
708
        }
709

            
710
8127
        Value::Object(constant) if constant.contains_key("ConstantAbstract") => {
711
357
            parse_abstract_matrix_as_expr(obj, scope)
712
        }
713

            
714
7770
        Value::Object(constant) if constant.contains_key("ConstantInt") => {
715
7392
            parse_constant(constant, scope)
716
        }
717
378
        Value::Object(constant) if constant.contains_key("ConstantBool") => {
718
42
            parse_constant(constant, scope)
719
        }
720

            
721
546
        _ => Err(fail("no_match")),
722
    }
723
148354
}
724

            
725
1260
fn parse_abs_lit(abs_set: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
726
1260
    let values = abs_set
727
1260
        .as_array()
728
1260
        .ok_or(error!("AbsLitSet is not an array"))?;
729
1260
    let expressions = values
730
1260
        .iter()
731
3192
        .map(|values| parse_expression(values, scope))
732
1260
        .collect::<Result<Vec<_>>>()?;
733

            
734
1260
    Ok(Expression::AbstractLiteral(
735
1260
        Metadata::new(),
736
1260
        AbstractLiteral::Set(expressions),
737
1260
    ))
738
1260
}
739

            
740
42
fn parse_abs_mset(abs_mset: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
741
42
    let values = abs_mset
742
42
        .as_array()
743
42
        .ok_or(error!("AbsLitMSet is not an array"))?;
744
42
    let expressions = values
745
42
        .iter()
746
126
        .map(|values| parse_expression(values, scope))
747
42
        .collect::<Result<Vec<_>>>()?;
748

            
749
42
    Ok(Expression::AbstractLiteral(
750
42
        Metadata::new(),
751
42
        AbstractLiteral::MSet(expressions),
752
42
    ))
753
42
}
754

            
755
84
fn parse_abs_tuple(abs_tuple: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
756
84
    let values = abs_tuple
757
84
        .as_array()
758
84
        .ok_or(error!("AbsLitTuple is not an array"))?;
759
84
    let expressions = values
760
84
        .iter()
761
210
        .map(|values| parse_expression(values, scope))
762
84
        .collect::<Result<Vec<_>>>()?;
763

            
764
84
    Ok(Expression::AbstractLiteral(
765
84
        Metadata::new(),
766
84
        AbstractLiteral::Tuple(expressions),
767
84
    ))
768
84
}
769

            
770
//parses an abstract record as an expression
771
21
fn parse_abs_record(abs_record: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
772
21
    let entries = abs_record
773
21
        .as_array()
774
21
        .ok_or(error!("AbsLitRecord is not an array"))?;
775
21
    let mut rec = vec![];
776

            
777
42
    for entry in entries {
778
42
        let entry = entry
779
42
            .as_array()
780
42
            .ok_or(error!("AbsLitRecord entry is not an array"))?;
781
42
        let name = entry[0]
782
42
            .as_object()
783
42
            .ok_or(error!("AbsLitRecord field name is not an object"))?["Name"]
784
42
            .as_str()
785
42
            .ok_or(error!("AbsLitRecord field name is not a string"))?;
786

            
787
42
        let value = parse_expression(&entry[1], scope)?;
788

            
789
42
        let name = Name::User(Ustr::from(name));
790
42
        let rec_entry = RecordValue {
791
42
            name: name.clone(),
792
42
            value,
793
42
        };
794
42
        rec.push(rec_entry);
795
    }
796

            
797
21
    Ok(Expression::AbstractLiteral(
798
21
        Metadata::new(),
799
21
        AbstractLiteral::Record(rec),
800
21
    ))
801
21
}
802

            
803
//parses an abstract function as an expression
804
126
fn parse_abs_function(abs_function: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
805
126
    let entries = abs_function
806
126
        .as_array()
807
126
        .ok_or(error!("AbsLitFunction is not an array"))?;
808
126
    let mut assignments = vec![];
809

            
810
252
    for entry in entries {
811
252
        let entry = entry
812
252
            .as_array()
813
252
            .ok_or(error!("Explicit function assignment is not an array"))?;
814
252
        let expression = entry
815
252
            .iter()
816
504
            .map(|values| parse_expression(values, scope))
817
252
            .collect::<Result<Vec<_>>>()?;
818
252
        let domain_value = expression
819
252
            .first()
820
252
            .ok_or(error!("Invalid function domain"))?;
821
252
        let codomain_value = expression
822
252
            .get(1)
823
252
            .ok_or(error!("Invalid function codomain"))?;
824
252
        let tuple = (domain_value.clone(), codomain_value.clone());
825
252
        assignments.push(tuple);
826
    }
827
126
    Ok(Expression::AbstractLiteral(
828
126
        Metadata::new(),
829
126
        AbstractLiteral::Function(assignments),
830
126
    ))
831
126
}
832

            
833
2184
fn parse_comprehension(
834
2184
    comprehension: &serde_json::Map<String, Value>,
835
2184
    scope: SymbolTablePtr,
836
2184
    comprehension_kind: Option<ACOperatorKind>,
837
2184
) -> Result<Expression> {
838
2184
    let fail = |stage: &str| -> Error {
839
        Error::Parse(format!("Could not parse comprehension at stage `{stage}`"))
840
    };
841

            
842
2184
    let value = &comprehension["Comprehension"];
843
2184
    let mut comprehension = ComprehensionBuilder::new(scope.clone());
844
2184
    let generator_symboltable = comprehension.generator_symboltable();
845
2184
    let return_expr_symboltable = comprehension.return_expr_symboltable();
846

            
847
2184
    let generators_and_guards_array = value
848
2184
        .pointer("/1")
849
2184
        .and_then(Value::as_array)
850
2184
        .ok_or_else(|| fail("Comprehension.pointer(/1).as_array"))?;
851
2184
    let generators_and_guards = generators_and_guards_array.iter();
852

            
853
2730
    for gen_or_guard in generators_and_guards {
854
2730
        let gen_or_guard_obj = gen_or_guard
855
2730
            .as_object()
856
2730
            .ok_or_else(|| fail("generator_or_guard.as_object"))?;
857
2730
        let (name, inner) = gen_or_guard_obj
858
2730
            .iter()
859
2730
            .next()
860
2730
            .ok_or_else(|| fail("generator_or_guard.iter().next"))?;
861
2730
        comprehension = match name.as_str() {
862
2730
            "Generator" => {
863
                // TODO: more things than GenDomainNoRepr and Single names here?
864
2415
                let generator_obj = inner
865
2415
                    .as_object()
866
2415
                    .ok_or_else(|| fail("Generator.inner.as_object"))?;
867
2415
                let (name, gen_inner) = generator_obj
868
2415
                    .iter()
869
2415
                    .next()
870
2415
                    .ok_or_else(|| fail("Generator.inner.iter().next"))?;
871
2415
                match name.as_str() {
872
2415
                    "GenDomainNoRepr" => {
873
2394
                        let name = gen_inner
874
2394
                            .pointer("/0/Single/Name")
875
2394
                            .and_then(Value::as_str)
876
2394
                            .ok_or_else(|| {
877
                                fail("GenDomainNoRepr.pointer(/0/Single/Name).as_str")
878
                            })?;
879
2394
                        let domain_obj = gen_inner
880
2394
                            .pointer("/1")
881
2394
                            .and_then(Value::as_object)
882
2394
                            .ok_or_else(|| fail("GenDomainNoRepr.pointer(/1).as_object"))?;
883
2394
                        let (domain_name, domain_value) = domain_obj
884
2394
                            .iter()
885
2394
                            .next()
886
2394
                            .ok_or_else(|| fail("GenDomainNoRepr.domain.iter().next"))?;
887
2394
                        let domain = parse_domain(
888
2394
                            domain_name,
889
2394
                            domain_value,
890
2394
                            &mut generator_symboltable.write(),
891
                        )?;
892
2394
                        comprehension.generator(DeclarationPtr::new_find(name.into(), domain))
893
                    }
894
                    // TODO: this is temporary until comprehensions support "in expr" generators
895
                    // currently only supports a single generator of this type
896
21
                    "GenInExpr" => return parse_in_expr_comprehension(scope, value, gen_inner),
897
                    _ => {
898
                        bug!("unknown generator type inside comprehension {name}");
899
                    }
900
                }
901
            }
902

            
903
315
            "Condition" => {
904
315
                let expr = parse_expression(inner, &generator_symboltable)
905
315
                    .map_err(|_| fail("Condition.parse_expression"))?;
906
315
                comprehension.guard(expr)
907
            }
908

            
909
            x => {
910
                bug!("unknown field inside comprehension {x}");
911
            }
912
        }
913
    }
914

            
915
2163
    let return_expr_value = value
916
2163
        .pointer("/0")
917
2163
        .ok_or_else(|| fail("Comprehension.pointer(/0)"))?;
918
2163
    let expr = parse_expression(return_expr_value, &return_expr_symboltable)
919
2163
        .map_err(|_| fail("Comprehension.return_expr.parse_expression"))?;
920

            
921
2163
    Ok(Expression::Comprehension(
922
2163
        Metadata::new(),
923
2163
        Moo::new(comprehension.with_return_value(expr, comprehension_kind)),
924
2163
    ))
925
2184
}
926

            
927
21
fn parse_in_expr_comprehension(
928
21
    scope: SymbolTablePtr,
929
21
    comprehension_value: &Value,
930
21
    gen_inner: &Value,
931
21
) -> Result<Expression> {
932
21
    let fail = |stage: &str| -> Error {
933
        Error::Parse(format!(
934
            "Could not parse GenInExpr comprehension at stage `{stage}`"
935
        ))
936
    };
937

            
938
21
    let name = gen_inner
939
21
        .pointer("/0/Single/Name")
940
21
        .and_then(Value::as_str)
941
21
        .ok_or_else(|| fail("GenInExpr.pointer(/0/Single/Name).as_str"))?;
942
21
    let generator_expr = gen_inner
943
21
        .pointer("/1")
944
21
        .ok_or_else(|| fail("GenInExpr.pointer(/1)"))?;
945
21
    let expr =
946
21
        parse_expression(generator_expr, &scope).map_err(|_| fail("GenInExpr.parse_expression"))?;
947

            
948
21
    let comprehension =
949
21
        AbstractComprehensionBuilder::new(&scope).new_expression_generator(expr, name.into());
950
21
    let return_expr_value = comprehension_value
951
21
        .pointer("/0")
952
21
        .ok_or_else(|| fail("comprehension_value.pointer(/0)"))?;
953
21
    let expr = parse_expression(return_expr_value, &comprehension.return_expr_symbols())
954
21
        .map_err(|_| fail("GenInExpr.return_expr.parse_expression"))?;
955

            
956
21
    Ok(Expression::AbstractComprehension(
957
21
        Metadata::new(),
958
21
        Moo::new(comprehension.with_return_value(expr)),
959
21
    ))
960
21
}
961

            
962
16844
fn parse_bin_op(
963
16844
    bin_op: &serde_json::Map<String, Value>,
964
16844
    scope: &SymbolTablePtr,
965
16844
) -> Result<Expression> {
966
    // we know there is a single key value pair in this object
967
    // extract the value, ignore the key
968
16844
    let (key, value) = bin_op
969
16844
        .into_iter()
970
16844
        .next()
971
16844
        .ok_or(error!("Binary op object is empty"))?;
972

            
973
16844
    let constructor = binary_operator(key.as_str())
974
16844
        .ok_or(error!(format!("Unknown binary operator `{}`", key)))?;
975

            
976
16844
    match &value {
977
16844
        Value::Array(bin_op_args) if bin_op_args.len() == 2 => {
978
16844
            let arg1 = parse_expression(&bin_op_args[0], scope)?;
979
16844
            let arg2 = parse_expression(&bin_op_args[1], scope)?;
980
16844
            Ok(constructor(Metadata::new(), Moo::new(arg1), Moo::new(arg2)))
981
        }
982
        _ => Err(error!("Binary operator arguments are not a 2-array")),
983
    }
984
16844
}
985

            
986
63
fn parse_table_op(
987
63
    op: &serde_json::Map<String, Value>,
988
63
    scope: &SymbolTablePtr,
989
63
) -> Result<Expression> {
990
63
    let args = op
991
63
        .get("MkOpTable")
992
63
        .ok_or(error!("MkOpTable missing"))?
993
63
        .as_array()
994
63
        .ok_or(error!("MkOpTable is not an array"))?;
995

            
996
63
    if args.len() != 2 {
997
        return Err(error!("MkOpTable arguments are not a 2-array"));
998
63
    }
999

            
63
    let tuple_expr = parse_expression(&args[0], scope)?;
63
    let allowed_rows_expr = parse_expression(&args[1], scope)?;
63
    let (tuple_elems, _) = tuple_expr
63
        .clone()
63
        .unwrap_matrix_unchecked()
63
        .ok_or(error!("MkOpTable first argument is not a matrix"))?;
63
    let (allowed_rows, _) = allowed_rows_expr
63
        .clone()
63
        .unwrap_matrix_unchecked()
63
        .ok_or(error!("MkOpTable second argument is not a matrix"))?;
168
    for row_expr in allowed_rows {
168
        let (row_elems, _) = row_expr
168
            .unwrap_matrix_unchecked()
168
            .ok_or(error!("MkOpTable row is not a matrix"))?;
168
        if row_elems.len() != tuple_elems.len() {
            return Err(error!("MkOpTable row width does not match tuple width"));
168
        }
    }
63
    Ok(Expression::Table(
63
        Metadata::new(),
63
        Moo::new(tuple_expr),
63
        Moo::new(allowed_rows_expr),
63
    ))
63
}
6090
fn parse_indexing_slicing_op(
6090
    op: &serde_json::Map<String, Value>,
6090
    scope: &SymbolTablePtr,
6090
) -> Result<Expression> {
    // we know there is a single key value pair in this object
    // extract the value, ignore the key
6090
    let (key, value) = op
6090
        .into_iter()
6090
        .next()
6090
        .ok_or(error!("Indexing/Slicing op object is empty"))?;
    // we know that this is meant to be a mkopindexing, so anything that goes wrong from here is a
    // bug!
    // Conjure does a[1,2,3] as MkOpIndexing(MkOpIndexing(MkOpIndexing(a,3),2),1).
    //
    // And  a[1,..,3] as MkOpIndexing(MkOpSlicing(MkOpIndexing(a,3)),1).
    //
    // However, we want this in a flattened form: Index(a, [1,2,3])
    let mut target: Expression;
6090
    let mut indices: Vec<Option<Expression>> = vec![];
    // true if this has no slicing, false otherwise.
6090
    let mut all_known = true;
6090
    match key.as_str() {
6090
        "MkOpIndexing" => {
5334
            match &value {
5334
                Value::Array(op_args) if op_args.len() == 2 => {
5334
                    target = parse_expression(&op_args[0], scope)?;
5334
                    indices.push(Some(parse_expression(&op_args[1], scope)?));
                }
                _ => return Err(error!("Unknown object inside MkOpIndexing")),
            };
        }
756
        "MkOpSlicing" => {
756
            all_known = false;
756
            match &value {
756
                Value::Array(op_args) if op_args.len() == 3 => {
756
                    target = parse_expression(&op_args[0], scope)?;
756
                    indices.push(None);
                }
                _ => return Err(error!("Unknown object inside MkOpSlicing")),
            };
        }
        _ => return Err(error!("Unknown indexing/slicing operator")),
    }
    loop {
7875
        match &mut target {
1533
            Expression::UnsafeIndex(_, new_target, new_indices) => {
1533
                indices.extend(new_indices.iter().cloned().rev().map(Some));
1533
                target = Moo::unwrap_or_clone(new_target.clone());
1533
            }
252
            Expression::UnsafeSlice(_, new_target, new_indices) => {
252
                all_known = false;
252
                indices.extend(new_indices.iter().cloned().rev());
252
                target = Moo::unwrap_or_clone(new_target.clone());
252
            }
            _ => {
                // not a slice or an index, we have reached the target.
6090
                break;
            }
        }
    }
6090
    indices.reverse();
6090
    if all_known {
        Ok(Expression::UnsafeIndex(
5082
            Metadata::new(),
5082
            Moo::new(target),
5082
            indices
5082
                .into_iter()
5082
                .collect::<Option<Vec<_>>>()
5082
                .ok_or(error!("Missing index in fully-known indexing operation"))?,
        ))
    } else {
1008
        Ok(Expression::UnsafeSlice(
1008
            Metadata::new(),
1008
            Moo::new(target),
1008
            indices,
1008
        ))
    }
6090
}
210
fn parse_flatten_op(
210
    op: &serde_json::Map<String, Value>,
210
    scope: &SymbolTablePtr,
210
) -> Result<Expression> {
210
    let args = op
210
        .get("MkOpFlatten")
210
        .ok_or(error!("MkOpFlatten missing"))?
210
        .as_array()
210
        .ok_or(error!("MkOpFlatten is not an array"))?;
210
    let first = args
210
        .first()
210
        .ok_or(error!("MkOpFlatten missing first argument"))?;
210
    let second = args
210
        .get(1)
210
        .ok_or(error!("MkOpFlatten missing second argument"))?;
210
    let n = parse_expression(first, scope).ok();
210
    let matrix = parse_expression(second, scope)?;
210
    if let Some(n) = n {
        Ok(Expression::Flatten(
            Metadata::new(),
            Some(Moo::new(n)),
            Moo::new(matrix),
        ))
    } else {
210
        Ok(Expression::Flatten(Metadata::new(), None, Moo::new(matrix)))
    }
210
}
14595
fn parse_unary_op(
14595
    un_op: &serde_json::Map<String, Value>,
14595
    scope: &SymbolTablePtr,
14595
) -> Result<Expression> {
14595
    let fail = |stage: &str| -> Error {
        Error::Parse(format!("Could not parse unary op at stage `{stage}`"))
    };
14595
    let (key, value) = un_op
14595
        .iter()
14595
        .next()
14595
        .ok_or_else(|| fail("un_op.iter().next"))?;
14595
    let constructor = unary_operator(key.as_str()).ok_or_else(|| fail("unary_operator"))?;
    // unops are the main things that contain comprehensions
    //
    // if the current expr is a quantifier like and/or/sum and it contains a comprehension, let the comprehension know what it is inside.
14595
    let arg = match value {
14595
        Value::Object(comprehension) if comprehension.contains_key("Comprehension") => {
2184
            let comprehension_kind = match key.as_str() {
2184
                "MkOpOr" => Some(ACOperatorKind::Or),
1701
                "MkOpAnd" => Some(ACOperatorKind::And),
420
                "MkOpSum" => Some(ACOperatorKind::Sum),
105
                "MkOpProduct" => Some(ACOperatorKind::Product),
105
                _ => None,
            };
2184
            parse_comprehension(comprehension, scope.clone(), comprehension_kind)
2184
                .map_err(|_| fail("value.Comprehension.parse_comprehension"))
        }
12411
        _ => parse_expression(value, scope).map_err(|_| fail("value.parse_expression")),
    }
14595
    .map_err(|_| fail("arg"))?;
14595
    Ok(constructor(Metadata::new(), Moo::new(arg)))
14595
}
// Takes in { AbstractLiteral: .... }
7749
fn parse_abstract_matrix_as_expr(
7749
    value: &serde_json::Value,
7749
    scope: &SymbolTablePtr,
7749
) -> Result<Expression> {
7749
    parser_trace!("trying to parse an abstract literal matrix");
7245
    let (values, domain_name, domain_value) =
7749
        if let Some(abs_lit_matrix) = value.pointer("/AbstractLiteral/AbsLitMatrix") {
6384
            parser_trace!(".. found JSON pointer /AbstractLiteral/AbstractLitMatrix");
6384
            let (domain_name, domain_value) = abs_lit_matrix
6384
                .pointer("/0")
6384
                .and_then(Value::as_object)
6384
                .and_then(|x| x.iter().next())
6384
                .ok_or(error!("AbsLitMatrix missing domain"))?;
6384
            let values = abs_lit_matrix
6384
                .pointer("/1")
6384
                .ok_or(error!("AbsLitMatrix missing values"))?;
6384
            Some((values, domain_name, domain_value))
        }
        // the input of this expression is constant - e.g. or([]), or([false]), min([2]), etc.
504
        else if let Some(const_abs_lit_matrix) =
1365
            value.pointer("/Constant/ConstantAbstract/AbsLitMatrix")
        {
504
            parser_trace!(".. found JSON pointer /Constant/ConstantAbstract/AbsLitMatrix");
504
            let (domain_name, domain_value) = const_abs_lit_matrix
504
                .pointer("/0")
504
                .and_then(Value::as_object)
504
                .and_then(|x| x.iter().next())
504
                .ok_or(error!("ConstantAbstract AbsLitMatrix missing domain"))?;
504
            let values = const_abs_lit_matrix
504
                .pointer("/1")
504
                .ok_or(error!("ConstantAbstract AbsLitMatrix missing values"))?;
504
            Some((values, domain_name, domain_value))
861
        } else if let Some(const_abs_lit_matrix) = value.pointer("/ConstantAbstract/AbsLitMatrix") {
357
            parser_trace!(".. found JSON pointer /ConstantAbstract/AbsLitMatrix");
357
            let (domain_name, domain_value) = const_abs_lit_matrix
357
                .pointer("/0")
357
                .and_then(Value::as_object)
357
                .and_then(|x| x.iter().next())
357
                .ok_or(error!("ConstantAbstract/AbsLitMatrix missing domain"))?;
357
            let values = const_abs_lit_matrix
357
                .pointer("/1")
357
                .ok_or(error!("ConstantAbstract/AbsLitMatrix missing values"))?;
357
            Some((values, domain_name, domain_value))
        } else {
504
            None
        }
7749
        .ok_or(error!("Could not parse abstract literal matrix"))?;
7245
    parser_trace!(".. found in domain and values in JSON:");
7245
    parser_trace!(".. .. index domain name {domain_name}");
7245
    parser_trace!(".. .. values {value}");
7245
    let args_parsed = values
7245
        .as_array()
7245
        .ok_or(error!("Matrix values are not an array"))?
7245
        .iter()
15582
        .map(|x| parse_expression(x, scope))
7245
        .collect::<Result<Vec<Expression>>>()?;
7245
    if !args_parsed.is_empty() {
7224
        parser_trace!(
            ".. successfully parsed values as expressions: {}, ... ",
            args_parsed[0]
        );
    } else {
21
        parser_trace!(".. successfully parsed empty values ",);
    }
7245
    let mut symbols = scope.write();
7245
    match parse_domain(domain_name, domain_value, &mut symbols) {
7245
        Ok(domain) => {
7245
            parser_trace!("... sucessfully parsed domain as {domain}");
7245
            Ok(into_matrix_expr![args_parsed;domain])
        }
        Err(_) => {
            parser_trace!("... failed to parse domain, creating a matrix without one.");
            Ok(into_matrix_expr![args_parsed])
        }
    }
7749
}
72708
fn parse_constant(
72708
    constant: &serde_json::Map<String, Value>,
72708
    scope: &SymbolTablePtr,
72708
) -> Result<Expression> {
72708
    match &constant.get("Constant") {
65274
        Some(Value::Object(int)) if int.contains_key("ConstantInt") => {
62712
            let int_32: i32 = match int["ConstantInt"]
62712
                .as_array()
62712
                .ok_or(error!("ConstantInt is not an array"))?[1]
62712
                .as_i64()
62712
                .ok_or(error!("ConstantInt does not contain int"))?
62712
                .try_into()
            {
62712
                Ok(x) => x,
                Err(_) => return Err(error!("ConstantInt cannot be represented as i32")),
            };
62712
            Ok(Expression::Atomic(
62712
                Metadata::new(),
62712
                Atom::Literal(Literal::Int(int_32)),
62712
            ))
        }
2562
        Some(Value::Object(b)) if b.contains_key("ConstantBool") => {
609
            let b: bool = b["ConstantBool"]
609
                .as_bool()
609
                .ok_or(error!("ConstantBool does not contain bool"))?;
609
            Ok(Expression::Atomic(
609
                Metadata::new(),
609
                Atom::Literal(Literal::Bool(b)),
609
            ))
        }
1953
        Some(Value::Object(int)) if int.contains_key("ConstantAbstract") => {
1953
            if let Some(Value::Object(obj)) = int.get("ConstantAbstract") {
1953
                if let Some(arr) = obj.get("AbsLitSet") {
1218
                    return parse_abs_lit(arr, scope);
735
                } else if let Some(arr) = obj.get("AbsLitMSet") {
42
                    return parse_abs_mset(arr, scope);
693
                } else if let Some(arr) = obj.get("AbsLitMatrix") {
504
                    return parse_abstract_matrix_as_expr(arr, scope);
189
                } else if let Some(arr) = obj.get("AbsLitTuple") {
84
                    return parse_abs_tuple(arr, scope);
105
                } else if let Some(arr) = obj.get("AbsLitRecord") {
21
                    return parse_abs_record(arr, scope);
84
                } else if let Some(arr) = obj.get("AbsLitFunction") {
84
                    return parse_abs_function(arr, scope);
                }
            }
            Err(error!("Unhandled ConstantAbstract literal type"))
        }
        // sometimes (e.g. constant matrices) we can have a ConstantInt / Constant bool that is
        // not wrapped in Constant
        None => {
7434
            let int_expr = constant
7434
                .get("ConstantInt")
7434
                .and_then(|x| x.as_array())
7434
                .and_then(|x| x[1].as_i64())
7434
                .and_then(|x| x.try_into().ok())
7434
                .map(|x| Expression::Atomic(Metadata::new(), Atom::Literal(Literal::Int(x))));
7434
            if let Some(expr) = int_expr {
7392
                return Ok(expr);
42
            }
42
            let bool_expr = constant
42
                .get("ConstantBool")
42
                .and_then(|x| x.as_bool())
42
                .map(|x| Expression::Atomic(Metadata::new(), Atom::Literal(Literal::Bool(x))));
42
            if let Some(expr) = bool_expr {
42
                return Ok(expr);
            }
            Err(error!(format!("Unhandled parse_constant {constant:#?}")))
        }
        otherwise => Err(error!(format!("Unhandled parse_constant {otherwise:#?}"))),
    }
72708
}