Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
nheko
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Iterations
Wiki
Requirements
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Locked files
Build
Pipelines
Jobs
Pipeline schedules
Test cases
Artifacts
Deploy
Releases
Package Registry
Container Registry
Model registry
Operate
Environments
Terraform modules
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Code review analytics
Issue analytics
Insights
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
Nheko Reborn
nheko
Commits
995b6212
Verified
Commit
995b6212
authored
3 years ago
by
Nicolas Werner
Browse files
Options
Downloads
Patches
Plain Diff
Fi lineendings
parent
028bcd5b
No related branches found
Branches containing commit
No related tags found
Tags containing commit
No related merge requests found
Pipeline
#1622
passed
3 years ago
Stage: build
Changes
2
Pipelines
1
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
src/RoomDirectoryModel.cpp
+209
-209
209 additions, 209 deletions
src/RoomDirectoryModel.cpp
src/RoomDirectoryModel.h
+98
-98
98 additions, 98 deletions
src/RoomDirectoryModel.h
with
307 additions
and
307 deletions
src/RoomDirectoryModel.cpp
+
209
−
209
View file @
995b6212
// SPDX-FileCopyrightText: 2021 Nheko Contributors
//
// SPDX-License-Identifier: GPL-3.0-or-later
#include
"RoomDirectoryModel.h"
#include
"Cache.h"
#include
"ChatPage.h"
#include
<algorithm>
RoomDirectoryModel
::
RoomDirectoryModel
(
QObject
*
parent
,
const
std
::
string
&
server
)
:
QAbstractListModel
(
parent
)
,
server_
(
server
)
{
connect
(
ChatPage
::
instance
(),
&
ChatPage
::
newRoom
,
this
,
[
this
](
const
QString
&
roomid
)
{
auto
roomid_
=
roomid
.
toStdString
();
int
i
=
0
;
for
(
const
auto
&
room
:
publicRoomsData_
)
{
if
(
room
.
room_id
==
roomid_
)
{
emit
dataChanged
(
index
(
i
),
index
(
i
),
{
Roles
::
CanJoin
});
break
;
}
i
++
;
}
});
connect
(
this
,
&
RoomDirectoryModel
::
fetchedRoomsBatch
,
this
,
&
RoomDirectoryModel
::
displayRooms
,
Qt
::
QueuedConnection
);
}
QHash
<
int
,
QByteArray
>
RoomDirectoryModel
::
roleNames
()
const
{
return
{
{
Roles
::
Name
,
"name"
},
{
Roles
::
Id
,
"roomid"
},
{
Roles
::
AvatarUrl
,
"avatarUrl"
},
{
Roles
::
Topic
,
"topic"
},
{
Roles
::
MemberCount
,
"numMembers"
},
{
Roles
::
Previewable
,
"canPreview"
},
{
Roles
::
CanJoin
,
"canJoin"
},
};
}
void
RoomDirectoryModel
::
resetDisplayedData
()
{
beginResetModel
();
prevBatch_
=
""
;
nextBatch_
=
""
;
canFetchMore_
=
true
;
publicRoomsData_
.
clear
();
endResetModel
();
}
void
RoomDirectoryModel
::
setMatrixServer
(
const
QString
&
s
)
{
server_
=
s
.
toStdString
();
nhlog
::
ui
()
->
debug
(
"Received matrix server: {}"
,
server_
);
resetDisplayedData
();
}
void
RoomDirectoryModel
::
setSearchTerm
(
const
QString
&
f
)
{
userSearchString_
=
f
.
toStdString
();
nhlog
::
ui
()
->
debug
(
"Received user query: {}"
,
userSearchString_
);
resetDisplayedData
();
}
bool
RoomDirectoryModel
::
canJoinRoom
(
const
QString
&
room
)
const
{
return
!
room
.
isEmpty
()
&&
cache
::
getRoomInfo
({
room
.
toStdString
()}).
empty
();
}
std
::
vector
<
std
::
string
>
RoomDirectoryModel
::
getViasForRoom
(
const
std
::
vector
<
std
::
string
>
&
aliases
)
{
std
::
vector
<
std
::
string
>
vias
;
vias
.
reserve
(
aliases
.
size
());
std
::
transform
(
aliases
.
begin
(),
aliases
.
end
(),
std
::
back_inserter
(
vias
),
[](
const
auto
&
alias
)
{
return
alias
.
substr
(
alias
.
find
(
":"
)
+
1
);
});
return
vias
;
}
void
RoomDirectoryModel
::
joinRoom
(
const
int
&
index
)
{
if
(
index
>=
0
&&
static_cast
<
size_t
>
(
index
)
<
publicRoomsData_
.
size
())
{
const
auto
&
chunk
=
publicRoomsData_
[
index
];
nhlog
::
ui
()
->
debug
(
"'Joining room {}"
,
chunk
.
room_id
);
ChatPage
::
instance
()
->
joinRoomVia
(
chunk
.
room_id
,
getViasForRoom
(
chunk
.
aliases
));
}
}
QVariant
RoomDirectoryModel
::
data
(
const
QModelIndex
&
index
,
int
role
)
const
{
if
(
hasIndex
(
index
.
row
(),
index
.
column
(),
index
.
parent
()))
{
const
auto
&
room_chunk
=
publicRoomsData_
[
index
.
row
()];
switch
(
role
)
{
case
Roles
::
Name
:
return
QString
::
fromStdString
(
room_chunk
.
name
);
case
Roles
::
Id
:
return
QString
::
fromStdString
(
room_chunk
.
room_id
);
case
Roles
::
AvatarUrl
:
return
QString
::
fromStdString
(
room_chunk
.
avatar_url
);
case
Roles
::
Topic
:
return
QString
::
fromStdString
(
room_chunk
.
topic
);
case
Roles
::
MemberCount
:
return
QVariant
::
fromValue
(
room_chunk
.
num_joined_members
);
case
Roles
::
Previewable
:
return
QVariant
::
fromValue
(
room_chunk
.
world_readable
);
case
Roles
::
CanJoin
:
return
canJoinRoom
(
QString
::
fromStdString
(
room_chunk
.
room_id
));
}
}
return
{};
}
void
RoomDirectoryModel
::
fetchMore
(
const
QModelIndex
&
)
{
if
(
!
canFetchMore_
)
return
;
nhlog
::
net
()
->
debug
(
"Fetching more rooms from mtxclient..."
);
mtx
::
requests
::
PublicRooms
req
;
req
.
limit
=
limit_
;
req
.
since
=
prevBatch_
;
req
.
filter
.
generic_search_term
=
userSearchString_
;
// req.third_party_instance_id = third_party_instance_id;
auto
requested_server
=
server_
;
reachedEndOfPagination_
=
false
;
emit
reachedEndOfPaginationChanged
();
loadingMoreRooms_
=
true
;
emit
loadingMoreRoomsChanged
();
http
::
client
()
->
post_public_rooms
(
req
,
[
requested_server
,
this
,
req
](
const
mtx
::
responses
::
PublicRooms
&
res
,
mtx
::
http
::
RequestErr
err
)
{
loadingMoreRooms_
=
false
;
emit
loadingMoreRoomsChanged
();
if
(
err
)
{
nhlog
::
net
()
->
error
(
"Failed to retrieve rooms from mtxclient - {} - {} - {}"
,
mtx
::
errors
::
to_string
(
err
->
matrix_error
.
errcode
),
err
->
matrix_error
.
error
,
err
->
parse_error
);
}
else
if
(
req
.
filter
.
generic_search_term
==
this
->
userSearchString_
&&
req
.
since
==
this
->
prevBatch_
&&
requested_server
==
this
->
server_
)
{
nhlog
::
net
()
->
debug
(
"signalling chunk to GUI thread"
);
emit
fetchedRoomsBatch
(
res
.
chunk
,
res
.
next_batch
);
}
},
requested_server
);
}
void
RoomDirectoryModel
::
displayRooms
(
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
fetched_rooms
,
const
std
::
string
&
next_batch
)
{
nhlog
::
net
()
->
debug
(
"Prev batch: {} | Next batch: {}"
,
prevBatch_
,
next_batch
);
if
(
fetched_rooms
.
empty
())
{
nhlog
::
net
()
->
error
(
"mtxclient helper thread yielded empty chunk!"
);
return
;
}
beginInsertRows
(
QModelIndex
(),
static_cast
<
int
>
(
publicRoomsData_
.
size
()),
static_cast
<
int
>
(
publicRoomsData_
.
size
()
+
fetched_rooms
.
size
())
-
1
);
this
->
publicRoomsData_
.
insert
(
this
->
publicRoomsData_
.
end
(),
fetched_rooms
.
begin
(),
fetched_rooms
.
end
());
endInsertRows
();
if
(
next_batch
.
empty
())
{
canFetchMore_
=
false
;
reachedEndOfPagination_
=
true
;
emit
reachedEndOfPaginationChanged
();
}
prevBatch_
=
next_batch
;
nhlog
::
ui
()
->
debug
(
"Finished loading rooms"
);
}
// SPDX-FileCopyrightText: 2021 Nheko Contributors
//
// SPDX-License-Identifier: GPL-3.0-or-later
#include
"RoomDirectoryModel.h"
#include
"Cache.h"
#include
"ChatPage.h"
#include
<algorithm>
RoomDirectoryModel
::
RoomDirectoryModel
(
QObject
*
parent
,
const
std
::
string
&
server
)
:
QAbstractListModel
(
parent
)
,
server_
(
server
)
{
connect
(
ChatPage
::
instance
(),
&
ChatPage
::
newRoom
,
this
,
[
this
](
const
QString
&
roomid
)
{
auto
roomid_
=
roomid
.
toStdString
();
int
i
=
0
;
for
(
const
auto
&
room
:
publicRoomsData_
)
{
if
(
room
.
room_id
==
roomid_
)
{
emit
dataChanged
(
index
(
i
),
index
(
i
),
{
Roles
::
CanJoin
});
break
;
}
i
++
;
}
});
connect
(
this
,
&
RoomDirectoryModel
::
fetchedRoomsBatch
,
this
,
&
RoomDirectoryModel
::
displayRooms
,
Qt
::
QueuedConnection
);
}
QHash
<
int
,
QByteArray
>
RoomDirectoryModel
::
roleNames
()
const
{
return
{
{
Roles
::
Name
,
"name"
},
{
Roles
::
Id
,
"roomid"
},
{
Roles
::
AvatarUrl
,
"avatarUrl"
},
{
Roles
::
Topic
,
"topic"
},
{
Roles
::
MemberCount
,
"numMembers"
},
{
Roles
::
Previewable
,
"canPreview"
},
{
Roles
::
CanJoin
,
"canJoin"
},
};
}
void
RoomDirectoryModel
::
resetDisplayedData
()
{
beginResetModel
();
prevBatch_
=
""
;
nextBatch_
=
""
;
canFetchMore_
=
true
;
publicRoomsData_
.
clear
();
endResetModel
();
}
void
RoomDirectoryModel
::
setMatrixServer
(
const
QString
&
s
)
{
server_
=
s
.
toStdString
();
nhlog
::
ui
()
->
debug
(
"Received matrix server: {}"
,
server_
);
resetDisplayedData
();
}
void
RoomDirectoryModel
::
setSearchTerm
(
const
QString
&
f
)
{
userSearchString_
=
f
.
toStdString
();
nhlog
::
ui
()
->
debug
(
"Received user query: {}"
,
userSearchString_
);
resetDisplayedData
();
}
bool
RoomDirectoryModel
::
canJoinRoom
(
const
QString
&
room
)
const
{
return
!
room
.
isEmpty
()
&&
cache
::
getRoomInfo
({
room
.
toStdString
()}).
empty
();
}
std
::
vector
<
std
::
string
>
RoomDirectoryModel
::
getViasForRoom
(
const
std
::
vector
<
std
::
string
>
&
aliases
)
{
std
::
vector
<
std
::
string
>
vias
;
vias
.
reserve
(
aliases
.
size
());
std
::
transform
(
aliases
.
begin
(),
aliases
.
end
(),
std
::
back_inserter
(
vias
),
[](
const
auto
&
alias
)
{
return
alias
.
substr
(
alias
.
find
(
":"
)
+
1
);
});
return
vias
;
}
void
RoomDirectoryModel
::
joinRoom
(
const
int
&
index
)
{
if
(
index
>=
0
&&
static_cast
<
size_t
>
(
index
)
<
publicRoomsData_
.
size
())
{
const
auto
&
chunk
=
publicRoomsData_
[
index
];
nhlog
::
ui
()
->
debug
(
"'Joining room {}"
,
chunk
.
room_id
);
ChatPage
::
instance
()
->
joinRoomVia
(
chunk
.
room_id
,
getViasForRoom
(
chunk
.
aliases
));
}
}
QVariant
RoomDirectoryModel
::
data
(
const
QModelIndex
&
index
,
int
role
)
const
{
if
(
hasIndex
(
index
.
row
(),
index
.
column
(),
index
.
parent
()))
{
const
auto
&
room_chunk
=
publicRoomsData_
[
index
.
row
()];
switch
(
role
)
{
case
Roles
::
Name
:
return
QString
::
fromStdString
(
room_chunk
.
name
);
case
Roles
::
Id
:
return
QString
::
fromStdString
(
room_chunk
.
room_id
);
case
Roles
::
AvatarUrl
:
return
QString
::
fromStdString
(
room_chunk
.
avatar_url
);
case
Roles
::
Topic
:
return
QString
::
fromStdString
(
room_chunk
.
topic
);
case
Roles
::
MemberCount
:
return
QVariant
::
fromValue
(
room_chunk
.
num_joined_members
);
case
Roles
::
Previewable
:
return
QVariant
::
fromValue
(
room_chunk
.
world_readable
);
case
Roles
::
CanJoin
:
return
canJoinRoom
(
QString
::
fromStdString
(
room_chunk
.
room_id
));
}
}
return
{};
}
void
RoomDirectoryModel
::
fetchMore
(
const
QModelIndex
&
)
{
if
(
!
canFetchMore_
)
return
;
nhlog
::
net
()
->
debug
(
"Fetching more rooms from mtxclient..."
);
mtx
::
requests
::
PublicRooms
req
;
req
.
limit
=
limit_
;
req
.
since
=
prevBatch_
;
req
.
filter
.
generic_search_term
=
userSearchString_
;
// req.third_party_instance_id = third_party_instance_id;
auto
requested_server
=
server_
;
reachedEndOfPagination_
=
false
;
emit
reachedEndOfPaginationChanged
();
loadingMoreRooms_
=
true
;
emit
loadingMoreRoomsChanged
();
http
::
client
()
->
post_public_rooms
(
req
,
[
requested_server
,
this
,
req
](
const
mtx
::
responses
::
PublicRooms
&
res
,
mtx
::
http
::
RequestErr
err
)
{
loadingMoreRooms_
=
false
;
emit
loadingMoreRoomsChanged
();
if
(
err
)
{
nhlog
::
net
()
->
error
(
"Failed to retrieve rooms from mtxclient - {} - {} - {}"
,
mtx
::
errors
::
to_string
(
err
->
matrix_error
.
errcode
),
err
->
matrix_error
.
error
,
err
->
parse_error
);
}
else
if
(
req
.
filter
.
generic_search_term
==
this
->
userSearchString_
&&
req
.
since
==
this
->
prevBatch_
&&
requested_server
==
this
->
server_
)
{
nhlog
::
net
()
->
debug
(
"signalling chunk to GUI thread"
);
emit
fetchedRoomsBatch
(
res
.
chunk
,
res
.
next_batch
);
}
},
requested_server
);
}
void
RoomDirectoryModel
::
displayRooms
(
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
fetched_rooms
,
const
std
::
string
&
next_batch
)
{
nhlog
::
net
()
->
debug
(
"Prev batch: {} | Next batch: {}"
,
prevBatch_
,
next_batch
);
if
(
fetched_rooms
.
empty
())
{
nhlog
::
net
()
->
error
(
"mtxclient helper thread yielded empty chunk!"
);
return
;
}
beginInsertRows
(
QModelIndex
(),
static_cast
<
int
>
(
publicRoomsData_
.
size
()),
static_cast
<
int
>
(
publicRoomsData_
.
size
()
+
fetched_rooms
.
size
())
-
1
);
this
->
publicRoomsData_
.
insert
(
this
->
publicRoomsData_
.
end
(),
fetched_rooms
.
begin
(),
fetched_rooms
.
end
());
endInsertRows
();
if
(
next_batch
.
empty
())
{
canFetchMore_
=
false
;
reachedEndOfPagination_
=
true
;
emit
reachedEndOfPaginationChanged
();
}
prevBatch_
=
next_batch
;
nhlog
::
ui
()
->
debug
(
"Finished loading rooms"
);
}
This diff is collapsed.
Click to expand it.
src/RoomDirectoryModel.h
+
98
−
98
View file @
995b6212
// SPDX-FileCopyrightText: 2021 Nheko Contributors
//
// SPDX-License-Identifier: GPL-3.0-or-later
#pragma once
#include
<QAbstractListModel>
#include
<QHash>
#include
<QString>
#include
<string>
#include
<vector>
#include
"MatrixClient.h"
#include
<mtx/responses/public_rooms.hpp>
#include
<mtxclient/http/errors.hpp>
#include
"Logging.h"
namespace
mtx
::
http
{
using
RequestErr
=
const
std
::
optional
<
mtx
::
http
::
ClientError
>
&
;
}
namespace
mtx
::
responses
{
struct
PublicRooms
;
}
class
RoomDirectoryModel
:
public
QAbstractListModel
{
Q_OBJECT
Q_PROPERTY
(
bool
loadingMoreRooms
READ
loadingMoreRooms
NOTIFY
loadingMoreRoomsChanged
)
Q_PROPERTY
(
bool
reachedEndOfPagination
READ
reachedEndOfPagination
NOTIFY
reachedEndOfPaginationChanged
)
public:
explicit
RoomDirectoryModel
(
QObject
*
parent
=
nullptr
,
const
std
::
string
&
server
=
""
);
enum
Roles
{
Name
=
Qt
::
UserRole
,
Id
,
AvatarUrl
,
Topic
,
MemberCount
,
Previewable
,
CanJoin
,
};
QHash
<
int
,
QByteArray
>
roleNames
()
const
override
;
QVariant
data
(
const
QModelIndex
&
index
,
int
role
)
const
override
;
inline
int
rowCount
(
const
QModelIndex
&
parent
=
QModelIndex
())
const
override
{
(
void
)
parent
;
return
static_cast
<
int
>
(
publicRoomsData_
.
size
());
}
bool
canFetchMore
(
const
QModelIndex
&
)
const
override
{
return
canFetchMore_
;
}
bool
loadingMoreRooms
()
const
{
return
loadingMoreRooms_
;
}
bool
reachedEndOfPagination
()
const
{
return
reachedEndOfPagination_
;
}
void
fetchMore
(
const
QModelIndex
&
)
override
;
Q_INVOKABLE
void
joinRoom
(
const
int
&
index
=
-
1
);
signals
:
void
fetchedRoomsBatch
(
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
rooms
,
const
std
::
string
&
next_batch
);
void
loadingMoreRoomsChanged
();
void
reachedEndOfPaginationChanged
();
public
slots
:
void
setMatrixServer
(
const
QString
&
s
=
""
);
void
setSearchTerm
(
const
QString
&
f
);
private
slots
:
void
displayRooms
(
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
rooms
,
const
std
::
string
&
next_batch
);
private
:
bool
canJoinRoom
(
const
QString
&
room
)
const
;
static
constexpr
size_t
limit_
=
50
;
std
::
string
server_
;
std
::
string
userSearchString_
;
std
::
string
prevBatch_
;
std
::
string
nextBatch_
;
bool
canFetchMore_
{
true
};
bool
loadingMoreRooms_
{
false
};
bool
reachedEndOfPagination_
{
false
};
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
publicRoomsData_
;
std
::
vector
<
std
::
string
>
getViasForRoom
(
const
std
::
vector
<
std
::
string
>
&
room
);
void
resetDisplayedData
();
};
// SPDX-FileCopyrightText: 2021 Nheko Contributors
//
// SPDX-License-Identifier: GPL-3.0-or-later
#pragma once
#include
<QAbstractListModel>
#include
<QHash>
#include
<QString>
#include
<string>
#include
<vector>
#include
"MatrixClient.h"
#include
<mtx/responses/public_rooms.hpp>
#include
<mtxclient/http/errors.hpp>
#include
"Logging.h"
namespace
mtx
::
http
{
using
RequestErr
=
const
std
::
optional
<
mtx
::
http
::
ClientError
>
&
;
}
namespace
mtx
::
responses
{
struct
PublicRooms
;
}
class
RoomDirectoryModel
:
public
QAbstractListModel
{
Q_OBJECT
Q_PROPERTY
(
bool
loadingMoreRooms
READ
loadingMoreRooms
NOTIFY
loadingMoreRoomsChanged
)
Q_PROPERTY
(
bool
reachedEndOfPagination
READ
reachedEndOfPagination
NOTIFY
reachedEndOfPaginationChanged
)
public:
explicit
RoomDirectoryModel
(
QObject
*
parent
=
nullptr
,
const
std
::
string
&
server
=
""
);
enum
Roles
{
Name
=
Qt
::
UserRole
,
Id
,
AvatarUrl
,
Topic
,
MemberCount
,
Previewable
,
CanJoin
,
};
QHash
<
int
,
QByteArray
>
roleNames
()
const
override
;
QVariant
data
(
const
QModelIndex
&
index
,
int
role
)
const
override
;
inline
int
rowCount
(
const
QModelIndex
&
parent
=
QModelIndex
())
const
override
{
(
void
)
parent
;
return
static_cast
<
int
>
(
publicRoomsData_
.
size
());
}
bool
canFetchMore
(
const
QModelIndex
&
)
const
override
{
return
canFetchMore_
;
}
bool
loadingMoreRooms
()
const
{
return
loadingMoreRooms_
;
}
bool
reachedEndOfPagination
()
const
{
return
reachedEndOfPagination_
;
}
void
fetchMore
(
const
QModelIndex
&
)
override
;
Q_INVOKABLE
void
joinRoom
(
const
int
&
index
=
-
1
);
signals
:
void
fetchedRoomsBatch
(
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
rooms
,
const
std
::
string
&
next_batch
);
void
loadingMoreRoomsChanged
();
void
reachedEndOfPaginationChanged
();
public
slots
:
void
setMatrixServer
(
const
QString
&
s
=
""
);
void
setSearchTerm
(
const
QString
&
f
);
private
slots
:
void
displayRooms
(
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
rooms
,
const
std
::
string
&
next_batch
);
private
:
bool
canJoinRoom
(
const
QString
&
room
)
const
;
static
constexpr
size_t
limit_
=
50
;
std
::
string
server_
;
std
::
string
userSearchString_
;
std
::
string
prevBatch_
;
std
::
string
nextBatch_
;
bool
canFetchMore_
{
true
};
bool
loadingMoreRooms_
{
false
};
bool
reachedEndOfPagination_
{
false
};
std
::
vector
<
mtx
::
responses
::
PublicRoomsChunk
>
publicRoomsData_
;
std
::
vector
<
std
::
string
>
getViasForRoom
(
const
std
::
vector
<
std
::
string
>
&
room
);
void
resetDisplayedData
();
};
This diff is collapsed.
Click to expand it.
Preview
0%
Loading
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment